public interface MessageQueueAdapter
Modifier and Type | Method and Description |
---|---|
void |
addDiscardListener(MessageQueue.DiscardListener listener) |
void |
clear() |
void |
enqeue(Message message) |
Message[] |
getAllMessages() |
Message[] |
getAtLeastMessages(int min) |
java.lang.String |
getDiscardPolicyName() |
Message |
getMessageBlocking() |
Message |
getMessageNoBlock() |
java.lang.String |
getOrderPolicyName() |
int |
getPendingMessagesCount() |
Message[] |
getUpToMessages(int max) |
boolean |
hasPendingMessages() |
void |
removeDiscardListener(MessageQueue.DiscardListener listener) |
void addDiscardListener(MessageQueue.DiscardListener listener)
void removeDiscardListener(MessageQueue.DiscardListener listener)
void enqeue(Message message) throws java.lang.InterruptedException
java.lang.InterruptedException
boolean hasPendingMessages() throws java.lang.InterruptedException
java.lang.InterruptedException
int getPendingMessagesCount() throws java.lang.InterruptedException
java.lang.InterruptedException
Message getMessageBlocking() throws java.lang.InterruptedException
java.lang.InterruptedException
Message getMessageNoBlock() throws java.lang.InterruptedException
java.lang.InterruptedException
Message[] getAllMessages() throws java.lang.InterruptedException
java.lang.InterruptedException
Message[] getUpToMessages(int max) throws java.lang.InterruptedException
java.lang.InterruptedException
Message[] getAtLeastMessages(int min) throws java.lang.InterruptedException
java.lang.InterruptedException
void clear()
java.lang.String getDiscardPolicyName()
java.lang.String getOrderPolicyName()