akka.dispatch
Class UnboundedPriorityMailbox

java.lang.Object
  akka.dispatch.UnboundedPriorityMailbox

All Implemented Interfaces:

MailboxType

public class UnboundedPriorityMailbox
extends java.lang.Object
implements MailboxType

UnboundedPriorityMailbox is an unbounded mailbox that allows for priorization of its contents. Extend this class and provide the Comparator in the constructor.

Constructor Summary

UnboundedPriorityMailbox(java.util.Comparator<Envelope> cmp)

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

Method Summary

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

UnboundedPriorityMailbox

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

UnboundedPriorityMailbox

public UnboundedPriorityMailbox(java.util.Comparator<Envelope> cmp)

Method Detail

cmp

public final java.util.Comparator<Envelope> cmp()

initialCapacity

public final int initialCapacity()

create

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

Specified by:

create in interface MailboxType