Package org.apache.pekko.dispatch
Class UnboundedStablePriorityMailbox
- java.lang.Object
-
- org.apache.pekko.dispatch.UnboundedStablePriorityMailbox
-
- All Implemented Interfaces:
MailboxType
,ProducesMessageQueue<UnboundedStablePriorityMailbox.MessageQueue>
public class UnboundedStablePriorityMailbox extends java.lang.Object implements MailboxType, ProducesMessageQueue<UnboundedStablePriorityMailbox.MessageQueue>
UnboundedStablePriorityMailbox is an unbounded mailbox that allows for prioritization of its contents. Unlike theUnboundedPriorityMailbox
it preserves ordering for messages of equal priority. Extend this class and provide the Comparator in the constructor.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
UnboundedStablePriorityMailbox.MessageQueue
-
Constructor Summary
Constructors Constructor Description UnboundedStablePriorityMailbox(java.util.Comparator<Envelope> cmp)
UnboundedStablePriorityMailbox(java.util.Comparator<Envelope> cmp, int initialCapacity)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.Comparator<Envelope>
cmp()
MessageQueue
create(scala.Option<ActorRef> owner, scala.Option<ActorSystem> system)
int
initialCapacity()
-
-
-
Method Detail
-
cmp
public java.util.Comparator<Envelope> cmp()
-
initialCapacity
public int initialCapacity()
-
create
public final MessageQueue create(scala.Option<ActorRef> owner, scala.Option<ActorSystem> system)
- Specified by:
create
in interfaceMailboxType
-
-