Package org.apache.pekko.dispatch
Class BoundedStablePriorityMailbox
- java.lang.Object
-
- org.apache.pekko.dispatch.BoundedStablePriorityMailbox
-
- All Implemented Interfaces:
MailboxType
,ProducesMessageQueue<BoundedStablePriorityMailbox.MessageQueue>
,ProducesPushTimeoutSemanticsMailbox
public class BoundedStablePriorityMailbox extends java.lang.Object implements MailboxType, ProducesMessageQueue<BoundedStablePriorityMailbox.MessageQueue>, ProducesPushTimeoutSemanticsMailbox
BoundedStablePriorityMailbox is a bounded mailbox that allows for prioritization of its contents. Unlike theBoundedPriorityMailbox
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
BoundedStablePriorityMailbox.MessageQueue
-
Constructor Summary
Constructors Constructor Description BoundedStablePriorityMailbox(java.util.Comparator<Envelope> cmp, int capacity, scala.concurrent.duration.Duration pushTimeOut)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description int
capacity()
java.util.Comparator<Envelope>
cmp()
MessageQueue
create(scala.Option<ActorRef> owner, scala.Option<ActorSystem> system)
scala.concurrent.duration.Duration
pushTimeOut()
-
-
-
Constructor Detail
-
BoundedStablePriorityMailbox
public BoundedStablePriorityMailbox(java.util.Comparator<Envelope> cmp, int capacity, scala.concurrent.duration.Duration pushTimeOut)
-
-
Method Detail
-
cmp
public final java.util.Comparator<Envelope> cmp()
-
capacity
public final int capacity()
-
pushTimeOut
public final scala.concurrent.duration.Duration pushTimeOut()
- Specified by:
pushTimeOut
in interfaceProducesPushTimeoutSemanticsMailbox
-
create
public final MessageQueue create(scala.Option<ActorRef> owner, scala.Option<ActorSystem> system)
- Specified by:
create
in interfaceMailboxType
-
-