Package 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 Description MessageQueue()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description UnboundedDequeBasedMailbox.MessageQueue
queue()
-
Methods inherited from class java.util.concurrent.LinkedBlockingDeque
add, addAll, addFirst, addLast, clear, contains, descendingIterator, drainTo, drainTo, element, forEach, 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, removeAll, removeFirst, removeFirstOccurrence, removeIf, removeLast, removeLastOccurrence, retainAll, size, spliterator, take, takeFirst, takeLast, toArray, toArray, toString
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface java.util.Collection
containsAll, equals, hashCode, isEmpty, parallelStream, stream, toArray
-
Methods inherited from interface akka.dispatch.QueueBasedMessageQueue
cleanUp, hasMessages, numberOfMessages
-
Methods inherited from interface akka.dispatch.UnboundedDequeBasedMessageQueue
dequeue, enqueue, enqueueFirst
-
-
-
-
Method Detail
-
queue
public final UnboundedDequeBasedMailbox.MessageQueue queue()
- Specified by:
queue
in interfaceDequeBasedMessageQueue
- Specified by:
queue
in interfaceQueueBasedMessageQueue
-
-