org.jacorb.notification.queue
Class BasicMessageQueueAdapter
java.lang.Object
org.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
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
BasicMessageQueueAdapter
public BasicMessageQueueAdapter(MessageQueue queue)
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()