org.jacorb.notification.queue
Class BasicMessageQueueAdapter

java.lang.Object
  extended byorg.jacorb.notification.queue.BasicMessageQueueAdapter
All Implemented Interfaces:
MessageQueueAdapter

public class BasicMessageQueueAdapter
extends java.lang.Object
implements MessageQueueAdapter

Version:
$Id: BasicMessageQueueAdapter.java,v 1.4 2005/04/27 10:40:22 alphonse.bendt Exp $
Author:
Alphonse Bendt

Constructor Summary
BasicMessageQueueAdapter(MessageQueue queue)
           
 
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()
           
 java.lang.String toString()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

BasicMessageQueueAdapter

public BasicMessageQueueAdapter(MessageQueue queue)
Method Detail

enqeue

public void enqeue(Message message)
Specified by:
enqeue in interface MessageQueueAdapter

hasPendingMessages

public boolean hasPendingMessages()
Specified by:
hasPendingMessages in interface MessageQueueAdapter

getPendingMessagesCount

public int getPendingMessagesCount()
Specified by:
getPendingMessagesCount in interface MessageQueueAdapter

getMessageBlocking

public Message getMessageBlocking()
                           throws java.lang.InterruptedException
Specified by:
getMessageBlocking in interface MessageQueueAdapter
Throws:
java.lang.InterruptedException

getMessageNoBlock

public Message getMessageNoBlock()
                          throws java.lang.InterruptedException
Specified by:
getMessageNoBlock in interface MessageQueueAdapter
Throws:
java.lang.InterruptedException

getAllMessages

public Message[] getAllMessages()
                         throws java.lang.InterruptedException
Specified by:
getAllMessages in interface MessageQueueAdapter
Throws:
java.lang.InterruptedException

getUpToMessages

public Message[] getUpToMessages(int max)
                          throws java.lang.InterruptedException
Specified by:
getUpToMessages in interface MessageQueueAdapter
Throws:
java.lang.InterruptedException

getAtLeastMessages

public Message[] getAtLeastMessages(int min)
                             throws java.lang.InterruptedException
Specified by:
getAtLeastMessages in interface MessageQueueAdapter
Throws:
java.lang.InterruptedException

clear

public void clear()
Specified by:
clear in interface MessageQueueAdapter

toString

public java.lang.String toString()