akka.dispatch
Class UnboundedPriorityMailbox.MessageQueue

java.lang.Object
  java.util.AbstractCollection<E>
      java.util.AbstractQueue<E>
          java.util.concurrent.PriorityBlockingQueue<Envelope>
              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