UnboundedMailbox.MessageQueue

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractQueue<E>

java.util.concurrent.ConcurrentLinkedQueue<Envelope>

org.apache.pekko.dispatch.UnboundedMailbox.MessageQueue

All Implemented Interfaces:: Serializable, Iterable<Envelope>, Collection<Envelope>, Queue<Envelope>, MessageQueue, MultipleConsumerSemantics, QueueBasedMessageQueue, UnboundedMessageQueueSemantics, UnboundedQueueBasedMessageQueue

Enclosing class:: UnboundedMailbox

public static class UnboundedMailbox.MessageQueue extends ConcurrentLinkedQueue<Envelope> implements UnboundedQueueBasedMessageQueue

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor

Description

MessageQueue()
Method Summary

Modifier and Type

Method

Description

final Queue<Envelope>

queue()

Methods inherited from class java.util.concurrent.ConcurrentLinkedQueue
add, addAll, clear, contains, forEach, isEmpty, iterator, offer, peek, poll, remove, removeAll, removeIf, retainAll, size, spliterator, toArray, toArray, toString

Methods inherited from class java.util.AbstractQueue
element, remove

Methods inherited from class java.util.AbstractCollection
containsAll

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, parallelStream, stream, toArray

Methods inherited from interface java.util.Queue
element, remove

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

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

Constructor Details
- MessageQueue
  
  public MessageQueue()
Method Details
- queue
  
  public final Queue<Envelope> queue()
  
  Specified by:
  
  queue in interface QueueBasedMessageQueue