MessageQueueAdapter

All Methods Instance Methods Abstract Methods
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

boolean hasPendingMessages()
                    throws java.lang.InterruptedException

int getPendingMessagesCount()
                     throws java.lang.InterruptedException

Message getMessageBlocking()
                    throws java.lang.InterruptedException

Message getMessageNoBlock()
                   throws java.lang.InterruptedException

Message[] getAllMessages()
                  throws java.lang.InterruptedException

Message[] getUpToMessages(int max)
                   throws java.lang.InterruptedException

Message[] getAtLeastMessages(int min)
                      throws java.lang.InterruptedException

java.lang.String getDiscardPolicyName()

Interface MessageQueueAdapter