akka.dispatch

Class UnboundedStablePriorityMailbox

java.lang.Object

akka.dispatch.UnboundedStablePriorityMailbox

All Implemented Interfaces:

MailboxType, ProducesMessageQueue<UnboundedStablePriorityMailbox.MessageQueue>

public class UnboundedStablePriorityMailbox
extends java.lang.Object
implements MailboxType, ProducesMessageQueue<UnboundedStablePriorityMailbox.MessageQueue>

UnboundedStablePriorityMailbox is an unbounded mailbox that allows for prioritization of its contents. Unlike the UnboundedPriorityMailbox 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 and Description
static class	UnboundedStablePriorityMailbox.MessageQueue

Constructor Summary

Constructors

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

Method Summary

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

UnboundedStablePriorityMailbox

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

UnboundedStablePriorityMailbox

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