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