akka.dispatch
Class NodeMessageQueue
java.lang.Object
java.util.concurrent.atomic.AtomicReference<AbstractNodeQueue.Node<T>>
akka.dispatch.AbstractNodeQueue<Envelope>
akka.dispatch.NodeMessageQueue
- All Implemented Interfaces:
- MessageQueue, UnboundedMessageQueueSemantics, java.io.Serializable
public class NodeMessageQueue
- extends AbstractNodeQueue<Envelope>
- implements MessageQueue, UnboundedMessageQueueSemantics
- See Also:
- Serialized Form
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. |
Methods inherited from class java.util.concurrent.atomic.AtomicReference |
compareAndSet, get, getAndSet, lazySet, set, toString, weakCompareAndSet |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
NodeMessageQueue
public NodeMessageQueue()
enqueue
public final void enqueue(ActorRef receiver,
Envelope handle)
- Description copied from interface:
MessageQueue
- Try to enqueue the message to this queue, or throw an exception.
- Specified by:
enqueue
in interface MessageQueue
- Parameters:
receiver
- (undocumented)handle
- (undocumented)
dequeue
public final Envelope dequeue()
- Description copied from interface:
MessageQueue
- Try to dequeue the next message from this queue, return null failing that.
- Specified by:
dequeue
in interface MessageQueue
- Returns:
- (undocumented)
numberOfMessages
public final int numberOfMessages()
- Description copied from interface:
MessageQueue
- Should return the current number of messages held in this queue; may
always return 0 if no other value is available efficiently. Do not use
this for testing for presence of messages, use
hasMessages
instead.
- Specified by:
numberOfMessages
in interface MessageQueue
- Returns:
- (undocumented)
hasMessages
public final boolean hasMessages()
- Description copied from interface:
MessageQueue
- Indicates whether this queue is non-empty.
- Specified by:
hasMessages
in interface MessageQueue
- Returns:
- (undocumented)
cleanUp
public final void cleanUp(ActorRef owner,
MessageQueue deadLetters)
- Description copied from interface:
MessageQueue
- Called when the mailbox this queue belongs to is disposed of. Normally it
is expected to transfer all remaining messages into the dead letter queue
which is passed in. The owner of this MessageQueue is passed in if
available (e.g. for creating DeadLetters()), “/deadletters” otherwise.
- Specified by:
cleanUp
in interface MessageQueue
- Parameters:
owner
- (undocumented)deadLetters
- (undocumented)