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