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

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()

BlockingDeque<Envelope>

queue()

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

Method Details
- 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
  
  BlockingDeque<Envelope> queue()
  
  Specified by:
  
  queue in interface DequeBasedMessageQueue
  
  Specified by:
  
  queue in interface QueueBasedMessageQueue