akka.dispatch
Class BoundedPriorityMailbox

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

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

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
static class BoundedPriorityMailbox.MessageQueue
           
 
Constructor Summary
BoundedPriorityMailbox(java.util.Comparator<Envelope> cmp, int capacity, scala.concurrent.duration.Duration pushTimeOut)
           
 
Method Summary
 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()

create

public final MessageQueue create(scala.Option<ActorRef> owner,
                                 scala.Option<ActorSystem> system)
Specified by:
create in interface MailboxType