akka.dispatch

Class UnboundedStablePriorityMailbox.MessageQueue

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractQueue<E>

akka.util.StablePriorityBlockingQueue<Envelope>

akka.dispatch.UnboundedStablePriorityMailbox.MessageQueue

All Implemented Interfaces:

MessageQueue, MultipleConsumerSemantics, QueueBasedMessageQueue, UnboundedMessageQueueSemantics, UnboundedQueueBasedMessageQueue, PriorityQueueStabilizer<Envelope>, java.lang.Iterable<Envelope>, java.util.Collection<Envelope>, java.util.Queue<Envelope>

Enclosing class:

UnboundedStablePriorityMailbox

public static class UnboundedStablePriorityMailbox.MessageQueue
extends StablePriorityBlockingQueue<Envelope>
implements UnboundedQueueBasedMessageQueue

Nested Class Summary

Nested classes/interfaces inherited from interface akka.util.PriorityQueueStabilizer

PriorityQueueStabilizer.WrappedElement<E>, PriorityQueueStabilizer.WrappedElementComparator<E>

Constructor Summary

Constructors

Constructor and Description
MessageQueue(int initialCapacity, java.util.Comparator<Envelope> cmp)

Method Summary

Modifier and Type	Method and Description
java.util.Queue<Envelope>	queue()

Methods inherited from class akka.util.StablePriorityBlockingQueue

backingQueue, seqNum

Methods inherited from class java.util.AbstractQueue

add, addAll, clear, element, remove

Methods inherited from class java.util.AbstractCollection

contains, containsAll, isEmpty, iterator, remove, removeAll, retainAll, size, toArray, toArray, toString

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 akka.util.PriorityQueueStabilizer

iterator, offer, peek, poll, size

Methods inherited from interface java.util.Queue

offer, peek, poll

Methods inherited from interface java.util.Collection

contains, containsAll, equals, hashCode, isEmpty, iterator, parallelStream, remove, removeAll, removeIf, retainAll, size, spliterator, stream, toArray, toArray

Methods inherited from interface java.lang.Iterable

forEach

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