public class DefaultMessageQueueAdapter extends 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) |
String |
getDiscardPolicyName() |
Message |
getMessageBlocking() |
Message |
getMessageNoBlock() |
String |
getOrderPolicyName() |
int |
getPendingMessagesCount() |
Message[] |
getUpToMessages(int max) |
boolean |
hasPendingMessages() |
void |
removeDiscardListener(MessageQueue.DiscardListener listener) |
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 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 © 2016 JacORB. All rights reserved.