Package org.apache.pekko.dispatch
Interface 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 TypeMethodDescriptiondequeue()Try to dequeue the next message from this queue, return null failing that.voidTry to enqueue the message to this queue, or throw an exception.voidenqueueFirst(ActorRef receiver, Envelope handle) scala.concurrent.duration.Durationqueue()Methods inherited from interface org.apache.pekko.dispatch.QueueBasedMessageQueue
cleanUp, hasMessages, numberOfMessages
-
Method Details
-
dequeue
Envelope dequeue()Description copied from interface:MessageQueueTry to dequeue the next message from this queue, return null failing that.- Specified by:
dequeuein interfaceMessageQueue
-
enqueue
Description copied from interface:MessageQueueTry to enqueue the message to this queue, or throw an exception.- Specified by:
enqueuein interfaceMessageQueue
-
enqueueFirst
- Specified by:
enqueueFirstin interfaceDequeBasedMessageQueueSemantics
-
pushTimeOut
scala.concurrent.duration.Duration pushTimeOut()- Specified by:
pushTimeOutin interfaceBoundedMessageQueueSemantics
-
queue
BlockingDeque<Envelope> queue()- Specified by:
queuein interfaceDequeBasedMessageQueue- Specified by:
queuein interfaceQueueBasedMessageQueue
-