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
receiver
- (undocumented)handle
- (undocumented)void enqueueFirst(ActorRef receiver, Envelope handle)
enqueueFirst
in interface DequeBasedMessageQueueSemantics
Envelope dequeue()
MessageQueue
dequeue
in interface MessageQueue