org.jacorb.notification.queue
Class AbstractBoundedEventHeap

java.lang.Object
  extended byorg.jacorb.notification.queue.AbstractBoundedEventQueue
      extended byorg.jacorb.notification.queue.AbstractBoundedEventHeap
All Implemented Interfaces:
MessageQueue
Direct Known Subclasses:
BoundedDeadlineEventQueue, BoundedPriorityEventQueue, BoundedReceiveTimeEventQueue

public abstract class AbstractBoundedEventHeap
extends AbstractBoundedEventQueue


Nested Class Summary
 
Nested classes inherited from class org.jacorb.notification.queue.MessageQueue
MessageQueue.DiscardListener
 
Constructor Summary
protected AbstractBoundedEventHeap(int capacity, EventQueueOverflowStrategy overflowStrategy, java.lang.Object lock, java.util.Comparator comparator)
           
 
Method Summary
protected  void addElement(Message event)
           
protected  Message[] getAllElements()
           
protected  Message[] getElements(int max)
           
protected  Message getNextElement()
           
protected  Message getNextHeapElement()
           
 int getSize()
          access the current size of this queue.
 boolean isEmpty()
          check if this queue is empty.
protected  Message removeFirstElement(java.util.Comparator comp)
           
 java.lang.String toString()
           
 
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
 

Constructor Detail

AbstractBoundedEventHeap

protected AbstractBoundedEventHeap(int capacity,
                                   EventQueueOverflowStrategy overflowStrategy,
                                   java.lang.Object lock,
                                   java.util.Comparator comparator)
Method Detail

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