akka.dispatch

Class UnboundedDequeBasedMailbox.MessageQueue

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractQueue<E>

java.util.concurrent.LinkedBlockingDeque<Envelope>

akka.dispatch.UnboundedDequeBasedMailbox.MessageQueue

All Implemented Interfaces:

DequeBasedMessageQueue, DequeBasedMessageQueueSemantics, MessageQueue, MultipleConsumerSemantics, QueueBasedMessageQueue, UnboundedDequeBasedMessageQueue, UnboundedDequeBasedMessageQueueSemantics, UnboundedMessageQueueSemantics, java.io.Serializable, java.lang.Iterable<Envelope>, java.util.Collection<Envelope>, java.util.concurrent.BlockingDeque<Envelope>, java.util.concurrent.BlockingQueue<Envelope>, java.util.Deque<Envelope>, java.util.Queue<Envelope>

Enclosing class:

UnboundedDequeBasedMailbox

public static class UnboundedDequeBasedMailbox.MessageQueue
extends java.util.concurrent.LinkedBlockingDeque<Envelope>
implements UnboundedDequeBasedMessageQueue

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
MessageQueue()

Method Summary

Modifier and Type	Method and Description
UnboundedDequeBasedMailbox.MessageQueue	queue()

Methods inherited from class java.util.concurrent.LinkedBlockingDeque

add, addFirst, addLast, clear, contains, descendingIterator, drainTo, drainTo, element, getFirst, getLast, iterator, offer, offer, offerFirst, offerFirst, offerLast, offerLast, peek, peekFirst, peekLast, poll, poll, pollFirst, pollFirst, pollLast, pollLast, pop, push, put, putFirst, putLast, remainingCapacity, remove, remove, removeFirst, removeFirstOccurrence, removeLast, removeLastOccurrence, size, spliterator, take, takeFirst, takeLast, toArray, toArray, toString

Methods inherited from class java.util.AbstractQueue

addAll

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.UnboundedDequeBasedMessageQueue

dequeue, enqueue, enqueueFirst

Methods inherited from interface akka.dispatch.QueueBasedMessageQueue

cleanUp, hasMessages, numberOfMessages

Methods inherited from interface java.util.Collection

addAll, containsAll, equals, hashCode, isEmpty, parallelStream, removeAll, removeIf, retainAll, stream

Methods inherited from interface java.lang.Iterable

forEach

Constructor Detail

MessageQueue

public MessageQueue()

Method Detail

queue

public final UnboundedDequeBasedMailbox.MessageQueue queue()

Specified by:

queue in interface DequeBasedMessageQueue

Specified by:

queue in interface QueueBasedMessageQueue