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 java.lang.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

Modifier and Type	Class	Description
static class	UnboundedPriorityMailbox.MessageQueue

Constructor Summary

Constructors

Constructor	Description
UnboundedPriorityMailbox(java.util.Comparator<Envelope> cmp)
UnboundedPriorityMailbox(java.util.Comparator<Envelope> cmp, int initialCapacity)

Method Summary

Modifier and Type	Method	Description
java.util.Comparator<Envelope>	cmp()
MessageQueue	create(scala.Option<ActorRef> owner, scala.Option<ActorSystem> system)
int	initialCapacity()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

UnboundedPriorityMailbox

public UnboundedPriorityMailbox(java.util.Comparator<Envelope> cmp,
                                int initialCapacity)

UnboundedPriorityMailbox

public UnboundedPriorityMailbox(java.util.Comparator<Envelope> cmp)

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 interface MailboxType