org.jacorb.notification.queue
Class AbstractBoundedEventHeap
java.lang.Object
org.jacorb.notification.queue.AbstractBoundedEventQueue
org.jacorb.notification.queue.AbstractBoundedEventHeap
- All Implemented Interfaces:
- MessageQueue
- Direct Known Subclasses:
- BoundedDeadlineEventQueue, BoundedPriorityEventQueue, BoundedReceiveTimeEventQueue
- public abstract class AbstractBoundedEventHeap
- extends AbstractBoundedEventQueue
Methods inherited from class org.jacorb.notification.queue.AbstractBoundedEventQueue |
addDiscardListener, getAllMessages, getDiscardPolicyName, getEarliestTimeout, getLeastPriority, getMessage, getMessages, getOldestElement, getOrderPolicyName, getYoungestElement, put, removeDiscardListener |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
AbstractBoundedEventHeap
protected AbstractBoundedEventHeap(int capacity,
EventQueueOverflowStrategy overflowStrategy,
java.lang.Object lock,
java.util.Comparator comparator)
removeFirstElement
protected final Message removeFirstElement(java.util.Comparator comp)
getAllElements
protected final Message[] getAllElements()
- Specified by:
getAllElements
in class AbstractBoundedEventQueue
isEmpty
public final boolean isEmpty()
- Description copied from interface:
MessageQueue
- check if this queue is empty.
getSize
public final int getSize()
- Description copied from interface:
MessageQueue
- access the current size of this queue.
addElement
protected final void addElement(Message event)
- Specified by:
addElement
in class AbstractBoundedEventQueue
getElements
protected final Message[] getElements(int max)
- Specified by:
getElements
in class AbstractBoundedEventQueue
getNextHeapElement
protected final Message getNextHeapElement()
getNextElement
protected final Message getNextElement()
- Specified by:
getNextElement
in class AbstractBoundedEventQueue
toString
public final java.lang.String toString()