org.jacorb.notification.queue

Class AbstractBoundedEventQueue

public abstract class AbstractBoundedEventQueue extends Object implements MessageQueue

Version: $Id: AbstractBoundedEventQueue.java,v 1.11 2006/02/25 15:28:40 alphonse.bendt Exp $

Author: Alphonse Bendt

Constructor Summary
protected AbstractBoundedEventQueue(int capacity, EventQueueOverflowStrategy overflowStrategy, Object lock)
Method Summary
voidaddDiscardListener(DiscardListener listener)
protected abstract voidaddElement(Message message)
protected abstract Message[]getAllElements()
Message[]getAllMessages(boolean wait)
StringgetDiscardPolicyName()
protected abstract MessagegetEarliestTimeout()
protected abstract Message[]getElements(int max)
protected abstract MessagegetLeastPriority()
MessagegetMessage(boolean wait)
Message[]getMessages(int max, boolean wait)
protected abstract MessagegetNextElement()
protected abstract MessagegetOldestElement()
abstract StringgetOrderPolicyName()
protected abstract MessagegetYoungestElement()
voidput(Message event)
voidremoveDiscardListener(DiscardListener listener)

Constructor Detail

AbstractBoundedEventQueue

protected AbstractBoundedEventQueue(int capacity, EventQueueOverflowStrategy overflowStrategy, Object lock)

Method Detail

addDiscardListener

public void addDiscardListener(DiscardListener listener)

addElement

protected abstract void addElement(Message message)

getAllElements

protected abstract Message[] getAllElements()

getAllMessages

public Message[] getAllMessages(boolean wait)

getDiscardPolicyName

public final String getDiscardPolicyName()

getEarliestTimeout

protected abstract Message getEarliestTimeout()

getElements

protected abstract Message[] getElements(int max)

getLeastPriority

protected abstract Message getLeastPriority()

getMessage

public Message getMessage(boolean wait)

getMessages

public Message[] getMessages(int max, boolean wait)

getNextElement

protected abstract Message getNextElement()

getOldestElement

protected abstract Message getOldestElement()

getOrderPolicyName

public abstract String getOrderPolicyName()

getYoungestElement

protected abstract Message getYoungestElement()

put

public void put(Message event)

removeDiscardListener

public void removeDiscardListener(DiscardListener listener)