public interface BoundedQueueBasedMessageQueue extends QueueBasedMessageQueue, BoundedMessageQueueSemantics
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.
|
java.util.concurrent.BlockingQueue<Envelope> |
queue() |
cleanUp, hasMessages, numberOfMessages
pushTimeOut
java.util.concurrent.BlockingQueue<Envelope> queue()
queue
in interface QueueBasedMessageQueue
void enqueue(ActorRef receiver, Envelope handle)
MessageQueue
enqueue
in interface MessageQueue
receiver
- (undocumented)handle
- (undocumented)Envelope dequeue()
MessageQueue
dequeue
in interface MessageQueue