Package org.apache.pekko.dispatch
Interface UnboundedDequeBasedMessageQueue
-
- All Superinterfaces:
DequeBasedMessageQueue
,DequeBasedMessageQueueSemantics
,MessageQueue
,MultipleConsumerSemantics
,QueueBasedMessageQueue
,UnboundedDequeBasedMessageQueueSemantics
,UnboundedMessageQueueSemantics
- All Known Implementing Classes:
UnboundedDequeBasedMailbox.MessageQueue
public interface UnboundedDequeBasedMessageQueue extends DequeBasedMessageQueue, UnboundedDequeBasedMessageQueueSemantics
UnboundedDequeBasedMessageQueueSemantics adds unbounded semantics to a DequeBasedMessageQueue, i.e. a non-blocking enqueue and dequeue.
-
-
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)
-
Methods inherited from interface org.apache.pekko.dispatch.DequeBasedMessageQueue
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 interfaceMessageQueue
-
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 interfaceMessageQueue
-
enqueueFirst
void enqueueFirst(ActorRef receiver, Envelope handle)
- Specified by:
enqueueFirst
in interfaceDequeBasedMessageQueueSemantics
-
-