akka.dispatch
Class BoundedMailbox.MessageQueue

java.lang.Object
  extended by java.util.AbstractCollection<E>
      extended by java.util.AbstractQueue<E>
          extended by java.util.concurrent.LinkedBlockingQueue<Envelope>
              extended by akka.dispatch.BoundedMailbox.MessageQueue
All Implemented Interfaces:
BoundedMessageQueueSemantics, BoundedQueueBasedMessageQueue, MessageQueue, MultipleConsumerSemantics, QueueBasedMessageQueue, java.io.Serializable, java.lang.Iterable<Envelope>, java.util.Collection<Envelope>, java.util.concurrent.BlockingQueue<Envelope>, java.util.Queue<Envelope>
Enclosing class:
BoundedMailbox

public static class BoundedMailbox.MessageQueue
extends java.util.concurrent.LinkedBlockingQueue<Envelope>
implements BoundedQueueBasedMessageQueue

See Also:
Serialized Form

Constructor Summary
BoundedMailbox.MessageQueue(int capacity, scala.concurrent.duration.FiniteDuration pushTimeOut)
           
 
Method Summary
 scala.concurrent.duration.FiniteDuration pushTimeOut()
           
 java.util.concurrent.BlockingQueue<Envelope> queue()
           
 
Methods inherited from class java.util.concurrent.LinkedBlockingQueue
clear, drainTo, drainTo, iterator, offer, offer, peek, poll, poll, put, remainingCapacity, remove, size, take, toArray, toArray, toString
 
Methods inherited from class java.util.AbstractQueue
add, addAll, element, remove
 
Methods inherited from class java.util.AbstractCollection
contains, containsAll, isEmpty, removeAll, retainAll
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface akka.dispatch.BoundedQueueBasedMessageQueue
dequeue, enqueue
 
Methods inherited from interface akka.dispatch.QueueBasedMessageQueue
cleanUp, hasMessages, numberOfMessages
 
Methods inherited from interface java.util.concurrent.BlockingQueue
add, contains
 
Methods inherited from interface java.util.Queue
element, remove
 
Methods inherited from interface java.util.Collection
addAll, containsAll, equals, hashCode, isEmpty, removeAll, retainAll
 

Constructor Detail

BoundedMailbox.MessageQueue

public BoundedMailbox.MessageQueue(int capacity,
                                   scala.concurrent.duration.FiniteDuration pushTimeOut)
Method Detail

pushTimeOut

public final scala.concurrent.duration.FiniteDuration pushTimeOut()
Specified by:
pushTimeOut in interface BoundedMessageQueueSemantics

queue

public final java.util.concurrent.BlockingQueue<Envelope> queue()
Specified by:
queue in interface BoundedQueueBasedMessageQueue
Specified by:
queue in interface QueueBasedMessageQueue