org.jacorb.notification.queue
Interface MessageQueueAdapter
- All Known Implementing Classes:
- DefaultMessageQueueAdapter, RWLockEventQueueDecorator
public interface MessageQueueAdapter
- Version:
- $Id: MessageQueueAdapter.java,v 1.3 2005/08/21 13:32:36 alphonse.bendt Exp $
- Author:
- Alphonse Bendt
addDiscardListener
void addDiscardListener(MessageQueue.DiscardListener listener)
removeDiscardListener
void removeDiscardListener(MessageQueue.DiscardListener listener)
enqeue
void enqeue(Message message)
throws java.lang.InterruptedException
- Throws:
java.lang.InterruptedException
hasPendingMessages
boolean hasPendingMessages()
throws java.lang.InterruptedException
- Throws:
java.lang.InterruptedException
getPendingMessagesCount
int getPendingMessagesCount()
throws java.lang.InterruptedException
- Throws:
java.lang.InterruptedException
getMessageBlocking
Message getMessageBlocking()
throws java.lang.InterruptedException
- Throws:
java.lang.InterruptedException
getMessageNoBlock
Message getMessageNoBlock()
throws java.lang.InterruptedException
- Throws:
java.lang.InterruptedException
getAllMessages
Message[] getAllMessages()
throws java.lang.InterruptedException
- Throws:
java.lang.InterruptedException
getUpToMessages
Message[] getUpToMessages(int max)
throws java.lang.InterruptedException
- Throws:
java.lang.InterruptedException
getAtLeastMessages
Message[] getAtLeastMessages(int min)
throws java.lang.InterruptedException
- Throws:
java.lang.InterruptedException
clear
void clear()
getDiscardPolicyName
java.lang.String getDiscardPolicyName()
getOrderPolicyName
java.lang.String getOrderPolicyName()