public class RWLockEventQueueDecorator extends java.lang.Object implements MessageQueueAdapter
Constructor and Description |
---|
RWLockEventQueueDecorator(MessageQueueAdapter initialDelegate) |
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 |
replaceDelegate(MessageQueueAdapter newDelegate) |
java.lang.String |
toString() |
public RWLockEventQueueDecorator(MessageQueueAdapter initialDelegate)
public void replaceDelegate(MessageQueueAdapter newDelegate) throws java.lang.InterruptedException
java.lang.InterruptedException
public void enqeue(Message message) throws java.lang.InterruptedException
enqeue
in interface MessageQueueAdapter
java.lang.InterruptedException
public boolean hasPendingMessages() throws java.lang.InterruptedException
hasPendingMessages
in interface MessageQueueAdapter
java.lang.InterruptedException
public int getPendingMessagesCount() throws java.lang.InterruptedException
getPendingMessagesCount
in interface MessageQueueAdapter
java.lang.InterruptedException
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