org.jacorb.notification.queue
public abstract class AbstractBoundedEventQueue extends Object implements MessageQueue
Version: $Id: AbstractBoundedEventQueue.java,v 1.11 2006/02/25 15:28:40 alphonse.bendt Exp $
Constructor Summary | |
---|---|
protected | AbstractBoundedEventQueue(int capacity, EventQueueOverflowStrategy overflowStrategy, Object lock) |
Method Summary | |
---|---|
void | addDiscardListener(DiscardListener listener) |
protected abstract void | addElement(Message message) |
protected abstract Message[] | getAllElements() |
Message[] | getAllMessages(boolean wait) |
String | getDiscardPolicyName() |
protected abstract Message | getEarliestTimeout() |
protected abstract Message[] | getElements(int max) |
protected abstract Message | getLeastPriority() |
Message | getMessage(boolean wait) |
Message[] | getMessages(int max, boolean wait) |
protected abstract Message | getNextElement() |
protected abstract Message | getOldestElement() |
abstract String | getOrderPolicyName() |
protected abstract Message | getYoungestElement() |
void | put(Message event) |
void | removeDiscardListener(DiscardListener listener) |