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 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(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

BoundedPriorityMailbox

public BoundedPriorityMailbox(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