akka.dispatch
Class UnboundedPriorityMailbox

java.lang.Object
  extended by akka.dispatch.UnboundedPriorityMailbox
All Implemented Interfaces:
MailboxType, ProducesMessageQueue<UnboundedPriorityMailbox.MessageQueue>

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

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


Nested Class Summary
static class UnboundedPriorityMailbox.MessageQueue
           
 
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 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