public interface ControlAwareMessageQueueSemantics extends QueueBasedMessageQueue
ControlMessage
with priority.Modifier and Type | Method and Description |
---|---|
java.util.Queue<Envelope> |
controlQueue() |
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.
|
boolean |
hasMessages()
Indicates whether this queue is non-empty.
|
int |
numberOfMessages()
Should return the current number of messages held in this queue; may
always return 0 if no other value is available efficiently.
|
java.util.Queue<Envelope> |
queue() |
cleanUp
java.util.Queue<Envelope> controlQueue()
java.util.Queue<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
int numberOfMessages()
MessageQueue
hasMessages
instead.numberOfMessages
in interface MessageQueue
numberOfMessages
in interface QueueBasedMessageQueue
boolean hasMessages()
MessageQueue
hasMessages
in interface MessageQueue
hasMessages
in interface QueueBasedMessageQueue