BoundedDequeBasedMailbox.MessageQueue

java.lang.Object
- java.util.AbstractCollection<E>
- - java.util.AbstractQueue<E>
  - - java.util.concurrent.LinkedBlockingDeque<Envelope>
    - - 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

Constructors
Constructor Description

MessageQueue(int capacity, scala.concurrent.duration.FiniteDuration pushTimeOut)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`scala.concurrent.duration.FiniteDuration`	`pushTimeOut()`
`BoundedDequeBasedMailbox.MessageQueue`	`queue()`

Methods inherited from class java.util.concurrent.LinkedBlockingDeque
add, addAll, addFirst, addLast, clear, contains, descendingIterator, drainTo, drainTo, element, forEach, 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, removeAll, removeFirst, removeFirstOccurrence, removeIf, removeLast, removeLastOccurrence, retainAll, size, spliterator, take, takeFirst, takeLast, toArray, toArray, toString

Methods inherited from class java.util.AbstractCollection
containsAll, isEmpty

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 java.util.Collection
containsAll, equals, hashCode, isEmpty, parallelStream, stream, toArray

Methods inherited from interface akka.dispatch.QueueBasedMessageQueue
cleanUp, hasMessages, numberOfMessages

- Constructor Detail
  - MessageQueue
```
public 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