public class BoundedStablePriorityMailbox extends java.lang.Object implements MailboxType, ProducesMessageQueue<BoundedStablePriorityMailbox.MessageQueue>, ProducesPushTimeoutSemanticsMailbox
BoundedPriorityMailbox
it preserves ordering for messages of equal priority.
Extend this class and provide the Comparator in the constructor.Modifier and Type | Class and Description |
---|---|
static class |
BoundedStablePriorityMailbox.MessageQueue |
Constructor and Description |
---|
BoundedStablePriorityMailbox(java.util.Comparator<Envelope> cmp,
int capacity,
scala.concurrent.duration.Duration pushTimeOut) |
Modifier and Type | Method and Description |
---|---|
int |
capacity() |
java.util.Comparator<Envelope> |
cmp() |
MessageQueue |
create(scala.Option<ActorRef> owner,
scala.Option<ActorSystem> system) |
scala.concurrent.duration.Duration |
pushTimeOut() |
public BoundedStablePriorityMailbox(java.util.Comparator<Envelope> cmp, int capacity, scala.concurrent.duration.Duration pushTimeOut)
public final java.util.Comparator<Envelope> cmp()
public final int capacity()
public final scala.concurrent.duration.Duration pushTimeOut()
pushTimeOut
in interface ProducesPushTimeoutSemanticsMailbox
public final MessageQueue create(scala.Option<ActorRef> owner, scala.Option<ActorSystem> system)
create
in interface MailboxType