|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface MessageQueue
A MessageQueue is one of the core components in forming an Akka Mailbox. The MessageQueue is where the normal messages that are sent to Actors will be enqueued (and subsequently dequeued) It needs to atleast support N producers and 1 consumer thread-safely.
Method Summary | |
---|---|
void |
cleanUp(ActorRef owner,
MessageQueue deadLetters)
Called when the mailbox this queue belongs to is disposed of. |
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. |
Method Detail |
---|
void enqueue(ActorRef receiver, Envelope handle)
Envelope dequeue()
int numberOfMessages()
hasMessages
instead.
boolean hasMessages()
void cleanUp(ActorRef owner, MessageQueue deadLetters)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |