Package org.apache.pekko.dispatch
Interface BoundedMessageQueueSemantics
-
- All Known Subinterfaces:
BoundedControlAwareMessageQueueSemantics
,BoundedDequeBasedMessageQueue
,BoundedDequeBasedMessageQueueSemantics
,BoundedQueueBasedMessageQueue
- All Known Implementing Classes:
BoundedControlAwareMailbox.MessageQueue
,BoundedDequeBasedMailbox.MessageQueue
,BoundedMailbox.MessageQueue
,BoundedNodeMessageQueue
,BoundedPriorityMailbox.MessageQueue
,BoundedStablePriorityMailbox.MessageQueue
public interface BoundedMessageQueueSemantics
BoundedMessageQueueSemantics adds bounded semantics to a QueueBasedMessageQueue, i.e. blocking enqueue with timeout.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description scala.concurrent.duration.Duration
pushTimeOut()
-