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
public void addDiscardListener(MessageQueue.DiscardListener listener)
removeDiscardListener
public void removeDiscardListener(MessageQueue.DiscardListener listener)
enqeue
public void enqeue(Message message)
throws java.lang.InterruptedException
- Throws:
java.lang.InterruptedException
hasPendingMessages
public boolean hasPendingMessages()
throws java.lang.InterruptedException
- Throws:
java.lang.InterruptedException
getPendingMessagesCount
public int getPendingMessagesCount()
throws java.lang.InterruptedException
- Throws:
java.lang.InterruptedException
getMessageBlocking
public Message getMessageBlocking()
throws java.lang.InterruptedException
- Throws:
java.lang.InterruptedException
getMessageNoBlock
public Message getMessageNoBlock()
throws java.lang.InterruptedException
- Throws:
java.lang.InterruptedException
getAllMessages
public Message[] getAllMessages()
throws java.lang.InterruptedException
- Throws:
java.lang.InterruptedException
getUpToMessages
public Message[] getUpToMessages(int max)
throws java.lang.InterruptedException
- Throws:
java.lang.InterruptedException
getAtLeastMessages
public Message[] getAtLeastMessages(int min)
throws java.lang.InterruptedException
- Throws:
java.lang.InterruptedException
clear
public void clear()
getDiscardPolicyName
public java.lang.String getDiscardPolicyName()
getOrderPolicyName
public java.lang.String getOrderPolicyName()