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

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)