public class DefaultMessageQueueAdapter extends java.lang.Object implements MessageQueueAdapter
Constructor and Description |
---|
DefaultMessageQueueAdapter(MessageQueue queue) |
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) |
java.lang.String |
toString() |
public DefaultMessageQueueAdapter(MessageQueue queue)
public void enqeue(Message message)
enqeue
in interface MessageQueueAdapter
public boolean hasPendingMessages()
hasPendingMessages
in interface MessageQueueAdapter
public int getPendingMessagesCount()
getPendingMessagesCount
in interface MessageQueueAdapter
public Message getMessageBlocking() throws java.lang.InterruptedException
getMessageBlocking
in interface MessageQueueAdapter
java.lang.InterruptedException
public Message getMessageNoBlock() throws java.lang.InterruptedException
getMessageNoBlock
in interface MessageQueueAdapter
java.lang.InterruptedException
public Message[] getAllMessages() throws java.lang.InterruptedException
getAllMessages
in interface MessageQueueAdapter
java.lang.InterruptedException
public Message[] getUpToMessages(int max) throws java.lang.InterruptedException
getUpToMessages
in interface MessageQueueAdapter
java.lang.InterruptedException
public Message[] getAtLeastMessages(int min) throws java.lang.InterruptedException
getAtLeastMessages
in interface MessageQueueAdapter
java.lang.InterruptedException
public void clear()
clear
in interface MessageQueueAdapter
public java.lang.String toString()
toString
in class java.lang.Object
public java.lang.String getDiscardPolicyName()
getDiscardPolicyName
in interface MessageQueueAdapter
public java.lang.String getOrderPolicyName()
getOrderPolicyName
in interface MessageQueueAdapter
public void addDiscardListener(MessageQueue.DiscardListener listener)
addDiscardListener
in interface MessageQueueAdapter
public void removeDiscardListener(MessageQueue.DiscardListener listener)
removeDiscardListener
in interface MessageQueueAdapter