UnboundedDequeBasedMailbox.MessageQueue

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractQueue<E>

java.util.concurrent.LinkedBlockingDeque<Envelope>

org.apache.pekko.dispatch.UnboundedDequeBasedMailbox.MessageQueue

All Implemented Interfaces:: Serializable, Iterable<Envelope>, Collection<Envelope>, BlockingDeque<Envelope>, BlockingQueue<Envelope>, Deque<Envelope>, Queue<Envelope>, DequeBasedMessageQueue, DequeBasedMessageQueueSemantics, MessageQueue, MultipleConsumerSemantics, QueueBasedMessageQueue, UnboundedDequeBasedMessageQueue, UnboundedDequeBasedMessageQueueSemantics, UnboundedMessageQueueSemantics

Enclosing class:: UnboundedDequeBasedMailbox

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

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor

Description

MessageQueue()
Method Summary

Modifier and Type

Method

Description

final 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.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
containsAll, equals, hashCode, isEmpty, parallelStream, stream, toArray

Methods inherited from interface org.apache.pekko.dispatch.QueueBasedMessageQueue
cleanUp, hasMessages, numberOfMessages

Methods inherited from interface org.apache.pekko.dispatch.UnboundedDequeBasedMessageQueue
dequeue, enqueue, enqueueFirst

Constructor Details
- MessageQueue
  
  public MessageQueue()
Method Details
- queue
  
  public final UnboundedDequeBasedMailbox.MessageQueue queue()
  
  Specified by:
  
  queue in interface DequeBasedMessageQueue
  
  Specified by:
  
  queue in interface QueueBasedMessageQueue