Package org.apache.pekko.dispatch
Class UnboundedStablePriorityMailbox.MessageQueue
- java.lang.Object
-
- java.util.AbstractCollection<E>
-
- java.util.AbstractQueue<E>
-
- org.apache.pekko.util.StablePriorityBlockingQueue<Envelope>
-
- org.apache.pekko.dispatch.UnboundedStablePriorityMailbox.MessageQueue
-
- All Implemented Interfaces:
java.lang.Iterable<Envelope>
,java.util.Collection<Envelope>
,java.util.Queue<Envelope>
,MessageQueue
,MultipleConsumerSemantics
,QueueBasedMessageQueue
,UnboundedMessageQueueSemantics
,UnboundedQueueBasedMessageQueue
,PriorityQueueStabilizer<Envelope>
- Enclosing class:
- UnboundedStablePriorityMailbox
public static class UnboundedStablePriorityMailbox.MessageQueue extends StablePriorityBlockingQueue<Envelope> implements UnboundedQueueBasedMessageQueue
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.pekko.util.PriorityQueueStabilizer
PriorityQueueStabilizer.WrappedElement<E>, PriorityQueueStabilizer.WrappedElementComparator<E>
-
-
Constructor Summary
Constructors Constructor Description MessageQueue(int initialCapacity, java.util.Comparator<Envelope> cmp)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.Queue<Envelope>
queue()
-
Methods inherited from class org.apache.pekko.util.StablePriorityBlockingQueue
backingQueue, org$apache$pekko$util$PriorityQueueStabilizer$_setter_$seqNum_$eq, seqNum
-
Methods inherited from class java.util.AbstractCollection
contains, containsAll, isEmpty, iterator, remove, removeAll, retainAll, size, 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
contains, containsAll, equals, hashCode, isEmpty, iterator, parallelStream, remove, removeAll, removeIf, retainAll, size, spliterator, stream, toArray, toArray, toArray
-
Methods inherited from interface org.apache.pekko.util.PriorityQueueStabilizer
iterator, offer, peek, poll, size
-
Methods inherited from interface org.apache.pekko.dispatch.QueueBasedMessageQueue
cleanUp, hasMessages, numberOfMessages
-
Methods inherited from interface org.apache.pekko.dispatch.UnboundedQueueBasedMessageQueue
dequeue, enqueue
-
-
-
-
Constructor Detail
-
MessageQueue
public MessageQueue(int initialCapacity, java.util.Comparator<Envelope> cmp)
-
-
Method Detail
-
queue
public final java.util.Queue<Envelope> queue()
- Specified by:
queue
in interfaceQueueBasedMessageQueue
-
-