org.jacorb.notification.queue

Class AbstractBoundedEventQueue

Implemented Interfaces:
EventQueue
Known Direct Subclasses:
BoundedDeadlineEventQueue, BoundedFifoEventQueue, BoundedPriorityEventQueue

public abstract class AbstractBoundedEventQueue
extends java.lang.Object
implements EventQueue

Version:
$Id: AbstractBoundedEventQueue.java,v 1.6 2004/05/06 12:39:59 nicolas Exp $

Author:
Alphonse Bendt

Constructor Summary

AbstractBoundedEventQueue(int capacity)
AbstractBoundedEventQueue(int capacity, EventQueueOverflowStrategy overflowStrategy)

Method Summary

protected void
addElement(Message event)
protected Message[]
getAllElements()
Message[]
getAllEvents(boolean wait)
protected Message
getEarliestTimeout()
protected Message[]
getElements(int max)
Message
getEvent(boolean wait)
Message[]
getEvents(int max, boolean wait)
protected Message
getLeastPriority()
protected Message
getNextElement()
protected Message
getOldestElement()
protected Message
getYoungestElement()
void
put(Message event)

Constructor Details

AbstractBoundedEventQueue

protected AbstractBoundedEventQueue(int capacity)


AbstractBoundedEventQueue

protected AbstractBoundedEventQueue(int capacity,
                                    EventQueueOverflowStrategy overflowStrategy)

Method Details

addElement

protected void addElement(Message event)


getAllElements

protected Message[] getAllElements()


getAllEvents

public Message[] getAllEvents(boolean wait)
            throws InterruptedException
Specified by:
getAllEvents in interface EventQueue


getEarliestTimeout

protected Message getEarliestTimeout()


getElements

protected Message[] getElements(int max)


getEvent

public Message getEvent(boolean wait)
            throws InterruptedException
Specified by:
getEvent in interface EventQueue


getEvents

public Message[] getEvents(int max,
                           boolean wait)
            throws InterruptedException
Specified by:
getEvents in interface EventQueue


getLeastPriority

protected Message getLeastPriority()


getNextElement

protected Message getNextElement()


getOldestElement

protected Message getOldestElement()


getYoungestElement

protected Message getYoungestElement()


put

public void put(Message event)
Specified by:
put in interface EventQueue