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
  
  Constructors
  Constructor Description
  
  MessageQueue(int initialCapacity, java.util.Comparator<Envelope> cmp)
- Method Summary
  
  All Methods Instance Methods Concrete Methods
  Modifier and Type Method Description
  
  java.util.Queue<Envelope> queue()
  - Methods inherited from class java.util.concurrent.PriorityBlockingQueue
    add, clear, comparator, contains, drainTo, drainTo, forEach, iterator, offer, offer, peek, poll, poll, put, remainingCapacity, remove, removeAll, removeIf, retainAll, size, spliterator, take, toArray, toArray, toString
  - Methods inherited from class java.util.AbstractQueue
    addAll, element, remove
  - Methods inherited from class java.util.AbstractCollection
    containsAll, isEmpty
  - Methods inherited from class java.lang.Object
    clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
  - Methods inherited from interface java.util.Collection
    addAll, containsAll, equals, hashCode, isEmpty, parallelStream, stream, toArray
  - Methods inherited from interface java.util.Queue
    element, remove
  - Methods inherited from interface akka.dispatch.QueueBasedMessageQueue
    cleanUp, hasMessages, numberOfMessages
  - Methods inherited from interface akka.dispatch.UnboundedQueueBasedMessageQueue
    dequeue, enqueue

Constructor Detail

MessageQueue

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

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