Package akka.dispatch

Class BoundedStablePriorityMailbox

java.lang.Object

akka.dispatch.BoundedStablePriorityMailbox

All Implemented Interfaces:

MailboxType, ProducesMessageQueue<BoundedStablePriorityMailbox.MessageQueue>, ProducesPushTimeoutSemanticsMailbox

public class BoundedStablePriorityMailbox
extends java.lang.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(java.util.Comparator<Envelope> cmp, int capacity, scala.concurrent.duration.Duration pushTimeOut)

Method Summary

Modifier and Type	Method	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

BoundedStablePriorityMailbox

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