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

Method Summary
 void addDiscardListener(MessageQueue.DiscardListener listener)
           
 void clear()
           
 void enqeue(Message message)
           
 Message[] getAllMessages()
           
 Message[] getAtLeastMessages(int min)
           
 java.lang.String getDiscardPolicyName()
           
 Message getMessageBlocking()
           
 Message getMessageNoBlock()
           
 java.lang.String getOrderPolicyName()
           
 int getPendingMessagesCount()
           
 Message[] getUpToMessages(int max)
           
 boolean hasPendingMessages()
           
 void removeDiscardListener(MessageQueue.DiscardListener listener)
           
 

Method Detail

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()