akka.dispatch
Class BoundedDequeBasedMailbox.MessageQueue

java.lang.Object
  extended by java.util.AbstractCollection<E>
      extended by java.util.AbstractQueue<E>
          extended by java.util.concurrent.LinkedBlockingDeque<Envelope>
              extended by akka.dispatch.BoundedDequeBasedMailbox.MessageQueue
All Implemented Interfaces:
BoundedDequeBasedMessageQueue, BoundedDequeBasedMessageQueueSemantics, BoundedMessageQueueSemantics, DequeBasedMessageQueue, DequeBasedMessageQueueSemantics, MessageQueue, MultipleConsumerSemantics, QueueBasedMessageQueue, java.io.Serializable, java.lang.Iterable<Envelope>, java.util.Collection<Envelope>, java.util.concurrent.BlockingDeque<Envelope>, java.util.concurrent.BlockingQueue<Envelope>, java.util.Deque<Envelope>, java.util.Queue<Envelope>
Enclosing class:
BoundedDequeBasedMailbox

public static class BoundedDequeBasedMailbox.MessageQueue
extends java.util.concurrent.LinkedBlockingDeque<Envelope>
implements BoundedDequeBasedMessageQueue

See Also:
Serialized Form

Constructor Summary
BoundedDequeBasedMailbox.MessageQueue(int capacity, scala.concurrent.duration.FiniteDuration pushTimeOut)
           
 
Method Summary
 scala.concurrent.duration.FiniteDuration pushTimeOut()
           
 BoundedDequeBasedMailbox.MessageQueue queue()
           
 
Methods inherited from class java.util.concurrent.LinkedBlockingDeque
add, addFirst, addLast, clear, contains, descendingIterator, drainTo, drainTo, element, getFirst, getLast, iterator, offer, offer, offerFirst, offerFirst, offerLast, offerLast, peek, peekFirst, peekLast, poll, poll, pollFirst, pollFirst, pollLast, pollLast, pop, push, put, putFirst, putLast, remainingCapacity, remove, remove, removeFirst, removeFirstOccurrence, removeLast, removeLastOccurrence, size, take, takeFirst, takeLast, toArray, toArray, toString
 
Methods inherited from class java.util.AbstractQueue
addAll
 
Methods inherited from class java.util.AbstractCollection
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.BoundedDequeBasedMessageQueue
dequeue, enqueue, enqueueFirst
 
Methods inherited from interface akka.dispatch.QueueBasedMessageQueue
cleanUp, hasMessages, numberOfMessages
 
Methods inherited from interface java.util.Collection
addAll, containsAll, equals, hashCode, isEmpty, removeAll, retainAll
 

Constructor Detail

BoundedDequeBasedMailbox.MessageQueue

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

pushTimeOut

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

queue

public final BoundedDequeBasedMailbox.MessageQueue queue()
Specified by:
queue in interface BoundedDequeBasedMessageQueue
Specified by:
queue in interface DequeBasedMessageQueue
Specified by:
queue in interface QueueBasedMessageQueue