org.jacorb.notification.queue
public class DefaultMessageQueueAdapter extends Object implements MessageQueueAdapter
Version: $Id: DefaultMessageQueueAdapter.java,v 1.1 2006/02/25 15:28:40 alphonse.bendt Exp $
Constructor Summary | |
---|---|
DefaultMessageQueueAdapter(MessageQueue queue) |
Method Summary | |
---|---|
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() |