org.jacorb.notification.queue
Interface MessageQueue

All Known Implementing Classes:
AbstractBoundedEventQueue

public interface MessageQueue

Version:
$Id: MessageQueue.java,v 1.1 2005/02/14 00:11:10 alphonse.bendt Exp $
Author:
Alphonse Bendt

Method Summary
 Message[] getAllMessages(boolean wait)
          get all Messages from this queue.
 Message getMessage(boolean wait)
          get the next Message from this queue. which particular event is selected depends on the underlying implementation.
 Message[] getMessages(int n, boolean wait)
          get up to n events from this queue.
 int getSize()
          access the current size of this queue.
 boolean isEmpty()
          check if this queue is empty.
 void put(Message event)
          put a Message into this queue.
 

Method Detail

getMessage

public Message getMessage(boolean wait)
                   throws java.lang.InterruptedException
get the next Message from this queue. which particular event is selected depends on the underlying implementation.

Parameters:
wait - a boolean value. If this parameter is set to true the queue will block until an element is available. If the parameter is set to false the queue will return null in case it is empty.
Throws:
java.lang.InterruptedException

getMessages

public Message[] getMessages(int n,
                             boolean wait)
                      throws java.lang.InterruptedException
get up to n events from this queue.

Parameters:
n - number of requested messages
wait - a boolean value. If this parameter is set to true the queue will block until an element is available. If the parameter is set to false the queue will return null in case it is empty.
Throws:
java.lang.InterruptedException

getAllMessages

public Message[] getAllMessages(boolean wait)
                         throws java.lang.InterruptedException
get all Messages from this queue.

Parameters:
wait - a boolean value. If this parameter is set to true the queue will block until an element is available. If the parameter is set to false the queue will return null in case it is empty.
Throws:
java.lang.InterruptedException

put

public void put(Message event)
put a Message into this queue.


isEmpty

public boolean isEmpty()
check if this queue is empty.


getSize

public int getSize()
access the current size of this queue.