Package org.apache.pekko.dispatch
Class UnboundedPriorityMailbox
java.lang.Object
org.apache.pekko.dispatch.UnboundedPriorityMailbox
- All Implemented Interfaces:
MailboxType,ProducesMessageQueue<UnboundedPriorityMailbox.MessageQueue>
public class UnboundedPriorityMailbox
extends Object
implements MailboxType, ProducesMessageQueue<UnboundedPriorityMailbox.MessageQueue>
UnboundedPriorityMailbox is an unbounded mailbox that allows for prioritization of its contents.
Extend this class and provide the Comparator in the constructor.
-
Nested Class Summary
Nested Classes -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptioncmp()final MessageQueuecreate(scala.Option<ActorRef> owner, scala.Option<ActorSystem> system) int
-
Constructor Details
-
UnboundedPriorityMailbox
-
UnboundedPriorityMailbox
-
-
Method Details
-
cmp
-
initialCapacity
public int initialCapacity() -
create
- Specified by:
createin interfaceMailboxType
-