org.jacorb.notification.queue
Interface MessageQueueAdapter

All Known Implementing Classes:
BasicMessageQueueAdapter, RWLockEventQueueDecorator

public interface MessageQueueAdapter

Version:
$Id: MessageQueueAdapter.java,v 1.2 2005/04/16 23:20:04 alphonse.bendt Exp $
Author:
Alphonse Bendt

Method Summary
 void clear()
           
 void enqeue(Message message)
           
 Message[] getAllMessages()
           
 Message[] getAtLeastMessages(int min)
           
 Message getMessageBlocking()
           
 Message getMessageNoBlock()
           
 int getPendingMessagesCount()
           
 Message[] getUpToMessages(int max)
           
 boolean hasPendingMessages()
           
 

Method Detail

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