akka.dispatch
Class UnboundedPriorityMailbox.MessageQueue

java.lang.Object
  extended by java.util.AbstractCollection<E>
      extended by java.util.AbstractQueue<E>
          extended by java.util.concurrent.PriorityBlockingQueue<Envelope>
              extended by akka.dispatch.UnboundedPriorityMailbox.MessageQueue
All Implemented Interfaces:
MessageQueue, MultipleConsumerSemantics, QueueBasedMessageQueue, UnboundedMessageQueueSemantics, UnboundedQueueBasedMessageQueue, java.io.Serializable, java.lang.Iterable<Envelope>, java.util.Collection<Envelope>, java.util.concurrent.BlockingQueue<Envelope>, java.util.Queue<Envelope>
Enclosing class:
UnboundedPriorityMailbox

public static class UnboundedPriorityMailbox.MessageQueue
extends java.util.concurrent.PriorityBlockingQueue<Envelope>
implements UnboundedQueueBasedMessageQueue

See Also:
Serialized Form

Constructor Summary
UnboundedPriorityMailbox.MessageQueue(int initialCapacity, java.util.Comparator<Envelope> cmp)
           
 
Method Summary
 java.util.Queue<Envelope> queue()
           
 
Methods inherited from class java.util.concurrent.PriorityBlockingQueue
add, clear, comparator, contains, drainTo, drainTo, iterator, offer, offer, peek, poll, poll, put, remainingCapacity, remove, size, take, toArray, toArray, toString
 
Methods inherited from class java.util.AbstractQueue
addAll, element, remove
 
Methods inherited from class java.util.AbstractCollection
containsAll, isEmpty, removeAll, retainAll
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface akka.dispatch.UnboundedQueueBasedMessageQueue
dequeue, enqueue
 
Methods inherited from interface akka.dispatch.QueueBasedMessageQueue
cleanUp, hasMessages, numberOfMessages
 
Methods inherited from interface java.util.Queue
element, remove
 
Methods inherited from interface java.util.Collection
addAll, containsAll, equals, hashCode, isEmpty, removeAll, retainAll
 

Constructor Detail

UnboundedPriorityMailbox.MessageQueue

public UnboundedPriorityMailbox.MessageQueue(int initialCapacity,
                                             java.util.Comparator<Envelope> cmp)
Method Detail

queue

public final java.util.Queue<Envelope> queue()
Specified by:
queue in interface QueueBasedMessageQueue