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 Object
implements MailboxType, ProducesMessageQueue<BoundedStablePriorityMailbox.MessageQueue>, ProducesPushTimeoutSemanticsMailbox

BoundedStablePriorityMailbox is a bounded mailbox that allows for prioritization of its contents. Unlike the BoundedPriorityMailbox 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(Comparator<Envelope> cmp, int capacity, scala.concurrent.duration.Duration pushTimeOut)

Method Summary

Modifier and Type	Method	Description
final int	capacity()
final Comparator<Envelope>	cmp()
final MessageQueue	create(scala.Option<ActorRef> owner, scala.Option<ActorSystem> system)
final scala.concurrent.duration.Duration	pushTimeOut()

Methods inherited from class java.lang.Object

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

Constructor Details

BoundedStablePriorityMailbox

public BoundedStablePriorityMailbox(Comparator<Envelope> cmp,
 int capacity,
 scala.concurrent.duration.Duration pushTimeOut)

Method Details

cmp

public final Comparator<Envelope> cmp()

capacity

public final int capacity()

pushTimeOut

public final scala.concurrent.duration.Duration pushTimeOut()

Specified by:

pushTimeOut in interface ProducesPushTimeoutSemanticsMailbox

create

public final MessageQueue create(scala.Option<ActorRef> owner,
 scala.Option<ActorSystem> system)

Specified by:

create in interface MailboxType