public interface BoundedDequeBasedMessageQueue extends DequeBasedMessageQueue, BoundedDequeBasedMessageQueueSemantics
Modifier and Type | Method and 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() |
cleanUp, hasMessages, numberOfMessages
scala.concurrent.duration.Duration pushTimeOut()
pushTimeOut
in interface BoundedMessageQueueSemantics
java.util.concurrent.BlockingDeque<Envelope> queue()
queue
in interface DequeBasedMessageQueue
queue
in interface QueueBasedMessageQueue
void enqueue(ActorRef receiver, Envelope handle)
MessageQueue
enqueue
in interface MessageQueue
void enqueueFirst(ActorRef receiver, Envelope handle)
enqueueFirst
in interface DequeBasedMessageQueueSemantics
Envelope dequeue()
MessageQueue
dequeue
in interface MessageQueue