Package org.apache.pekko.dispatch
Class BoundedPriorityMailbox
- java.lang.Object
-
- org.apache.pekko.dispatch.BoundedPriorityMailbox
-
- All Implemented Interfaces:
MailboxType
,ProducesMessageQueue<BoundedPriorityMailbox.MessageQueue>
,ProducesPushTimeoutSemanticsMailbox
public class BoundedPriorityMailbox extends java.lang.Object implements MailboxType, ProducesMessageQueue<BoundedPriorityMailbox.MessageQueue>, ProducesPushTimeoutSemanticsMailbox
BoundedPriorityMailbox is a bounded mailbox that allows for prioritization of its contents. Extend this class and provide the Comparator in the constructor.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
BoundedPriorityMailbox.MessageQueue
-
Constructor Summary
Constructors Constructor Description BoundedPriorityMailbox(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
-
BoundedPriorityMailbox
public BoundedPriorityMailbox(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
-
-