akka.dispatch

Class BoundedPriorityMailbox

java.lang.Object

akka.dispatch.BoundedPriorityMailbox

All Implemented Interfaces:

MailboxType, ProducesMessageQueue<BoundedPriorityMailbox.MessageQueue>, ProducesPushTimeoutSemanticsMailbox

public class BoundedPriorityMailbox
extends java.lang.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 and Description
static class	BoundedPriorityMailbox.MessageQueue

Constructor Summary

Constructors

Constructor and Description
BoundedPriorityMailbox(java.util.Comparator<Envelope> cmp, int capacity, scala.concurrent.duration.Duration pushTimeOut)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

BoundedPriorityMailbox

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

Method Detail

cmp

public final java.util.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