BoundedDequeBasedMessageQueue

All Superinterfaces:

BoundedDequeBasedMessageQueueSemantics, BoundedMessageQueueSemantics, DequeBasedMessageQueue, DequeBasedMessageQueueSemantics, MessageQueue, MultipleConsumerSemantics, QueueBasedMessageQueue

All Known Implementing Classes:

BoundedDequeBasedMailbox.MessageQueue
```
public interface BoundedDequeBasedMessageQueue
extends DequeBasedMessageQueue, BoundedDequeBasedMessageQueueSemantics
```
BoundedMessageQueueSemantics adds bounded semantics to a DequeBasedMessageQueue, i.e. blocking enqueue with timeout.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`Envelope`	`dequeue()`	Try to dequeue the next message from this queue, return null failing that.
`void`	`enqueue(ActorRef receiver, Envelope handle)`	Try to enqueue the message to this queue, or throw an exception.
`void`	`enqueueFirst(ActorRef receiver, Envelope handle)`
`scala.concurrent.duration.Duration`	`pushTimeOut()`
`java.util.concurrent.BlockingDeque<Envelope>`	`queue()`

Methods inherited from interface org.apache.pekko.dispatch.QueueBasedMessageQueue
cleanUp, hasMessages, numberOfMessages

- Method Detail
  - dequeue
```
Envelope dequeue()
```
    Description copied from interface: MessageQueue
    
    Try to dequeue the next message from this queue, return null failing that.
    
    Specified by:
    
    dequeue in interface MessageQueue
  - enqueue
```
void enqueue(ActorRef receiver,
             Envelope handle)
```
    Description copied from interface: MessageQueue
    
    Try to enqueue the message to this queue, or throw an exception.
    
    Specified by:
    
    enqueue in interface MessageQueue
  - enqueueFirst
```
void enqueueFirst(ActorRef receiver,
                  Envelope handle)
```
    Specified by:
    
    enqueueFirst in interface DequeBasedMessageQueueSemantics
  - pushTimeOut
```
scala.concurrent.duration.Duration pushTimeOut()
```
    Specified by:
    
    pushTimeOut in interface BoundedMessageQueueSemantics
  - queue
```
java.util.concurrent.BlockingDeque<Envelope> queue()
```
    Specified by:
    
    queue in interface DequeBasedMessageQueue
    
    Specified by:
    
    queue in interface QueueBasedMessageQueue