public interface MessageQueue
Modifier and Type | Interface and Description |
---|---|
static interface |
MessageQueue.DiscardListener |
Modifier and Type | Method and Description |
---|---|
void |
addDiscardListener(MessageQueue.DiscardListener listener) |
Message[] |
getAllMessages(boolean wait)
get all Messages from this queue.
|
String |
getDiscardPolicyName() |
Message |
getMessage(boolean wait)
get the next Message from this queue.
|
Message[] |
getMessages(int n,
boolean wait)
get up to
n events from this queue. |
String |
getOrderPolicyName() |
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.
|
void |
removeDiscardListener(MessageQueue.DiscardListener listener) |
void addDiscardListener(MessageQueue.DiscardListener listener)
void removeDiscardListener(MessageQueue.DiscardListener listener)
Message getMessage(boolean wait) throws InterruptedException
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.InterruptedException
Message[] getMessages(int n, boolean wait) throws InterruptedException
n
events from this queue.n
- number of requested messageswait
- 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.InterruptedException
Message[] getAllMessages(boolean wait) throws InterruptedException
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.InterruptedException
void put(Message event)
boolean isEmpty()
int getSize()
String getOrderPolicyName()
String getDiscardPolicyName()
Copyright © 2016 JacORB. All rights reserved.