public class RWLockEventQueueDecorator extends 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) |
String |
getDiscardPolicyName() |
Message |
getMessageBlocking() |
Message |
getMessageNoBlock() |
String |
getOrderPolicyName() |
int |
getPendingMessagesCount() |
Message[] |
getUpToMessages(int max) |
boolean |
hasPendingMessages() |
void |
removeDiscardListener(MessageQueue.DiscardListener listener) |
void |
replaceDelegate(MessageQueueAdapter newDelegate) |
String |
toString() |
public RWLockEventQueueDecorator(MessageQueueAdapter initialDelegate)
public void replaceDelegate(MessageQueueAdapter newDelegate) throws InterruptedException
InterruptedException
public void enqeue(Message message) throws InterruptedException
enqeue
in interface MessageQueueAdapter
InterruptedException
public boolean hasPendingMessages() throws InterruptedException
hasPendingMessages
in interface MessageQueueAdapter
InterruptedException
public int getPendingMessagesCount() throws InterruptedException
getPendingMessagesCount
in interface MessageQueueAdapter
InterruptedException
public Message getMessageBlocking() throws InterruptedException
getMessageBlocking
in interface MessageQueueAdapter
InterruptedException
public Message getMessageNoBlock() throws InterruptedException
getMessageNoBlock
in interface MessageQueueAdapter
InterruptedException
public Message[] getAllMessages() throws InterruptedException
getAllMessages
in interface MessageQueueAdapter
InterruptedException
public Message[] getUpToMessages(int max) throws InterruptedException
getUpToMessages
in interface MessageQueueAdapter
InterruptedException
public Message[] getAtLeastMessages(int min) throws InterruptedException
getAtLeastMessages
in interface MessageQueueAdapter
InterruptedException
public void clear()
clear
in interface MessageQueueAdapter
public String getDiscardPolicyName()
getDiscardPolicyName
in interface MessageQueueAdapter
public 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
Copyright © 2017 JacORB. All rights reserved.