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

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