UnboundedPriorityMailbox.MessageQueue

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractQueue<E>

java.util.concurrent.PriorityBlockingQueue<Envelope>

org.apache.pekko.dispatch.UnboundedPriorityMailbox.MessageQueue

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

Enclosing class:: UnboundedPriorityMailbox

public static class UnboundedPriorityMailbox.MessageQueue extends PriorityBlockingQueue<Envelope> implements UnboundedQueueBasedMessageQueue

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor

Description

MessageQueue(int initialCapacity, Comparator<Envelope> cmp)
Method Summary

Modifier and Type

Method

Description

final Queue<Envelope>

queue()

Methods inherited from class java.util.concurrent.PriorityBlockingQueue
add, clear, comparator, contains, drainTo, drainTo, forEach, iterator, offer, offer, peek, poll, poll, put, remainingCapacity, remove, removeAll, removeIf, retainAll, size, spliterator, take, toArray, toArray, toString

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

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
addAll, containsAll, equals, hashCode, isEmpty, 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(int initialCapacity, Comparator<Envelope> cmp)
Method Details
- queue
  
  public final Queue<Envelope> queue()
  
  Specified by:
  
  queue in interface QueueBasedMessageQueue