Uses of Class
groovyx.gpars.actor.ActorMessage

Packages that use ActorMessage

Package	Description
groovyx.gpars.actor	This package holds classes forming the public actor API.
groovyx.gpars.actor.impl	This package holds classes some non-public aspects of actor implementation.

Uses of ActorMessage in groovyx.gpars.actor

Fields in groovyx.gpars.actor declared as ActorMessage

Modifier and Type	Field and Description
protected static ActorMessage	Actor.START_MESSAGE
protected static ActorMessage	Actor.STOP_MESSAGE
protected static ActorMessage	Actor.TERMINATE_MESSAGE
protected static ActorMessage	Actor.TIMEOUT_MESSAGE

Methods in groovyx.gpars.actor that return ActorMessage

Modifier and Type	Method and Description
static <T> ActorMessage	ActorMessage.build(T payLoad) Factory method to create instances of ActorMessage with given payload.
protected ActorMessage	Actor.createActorMessage(java.lang.Object message)
protected ActorMessage	AbstractLoopingActor.sweepNextMessage() Removes the head of the message queue
protected abstract ActorMessage	Actor.sweepNextMessage() Removes the head of the message queue
protected ActorMessage	Actor.RemoteActor.sweepNextMessage()

Methods in groovyx.gpars.actor that return types with arguments of type ActorMessage

Modifier and Type	Method and Description
(package private) java.util.List<ActorMessage>	Actor.sweepQueue() Clears the message queue returning all the messages it held.

Methods in groovyx.gpars.actor with parameters of type ActorMessage

Modifier and Type	Method and Description
private java.lang.Object	BlockingActor.enhanceAndUnwrap(ActorMessage message)
private void	BlockingActor.enhanceReplies(ActorMessage message) Adds reply and replyIfExists methods to the current Actor and the message.
private void	AbstractLoopingActor.runEnhancedWithoutRepliesOnMessages(ActorMessage message, groovy.lang.Closure code, java.lang.Object arguments)

Uses of ActorMessage in groovyx.gpars.actor.impl

Fields in groovyx.gpars.actor.impl declared as ActorMessage

Modifier and Type	Field and Description
private ActorMessage	MessageStream.SendTo.message
(package private) ActorMessage	SequentialProcessingActor.Node.msg

Methods in groovyx.gpars.actor.impl that return ActorMessage

Modifier and Type	Method and Description
private ActorMessage	SequentialProcessingActor.awaitNextMessage(long endTime) Holds common functionality for takeMessage() methods.
ActorMessage	MessageStream.SendTo.getMessage()
protected ActorMessage	SequentialProcessingActor.pollMessage() Polls a message from the queues
private ActorMessage	SequentialProcessingActor.retrieveNextMessage() Takes the next message from the outputQueue, decrements the counter and possibly throws control exceptions
protected ActorMessage	SequentialProcessingActor.sweepNextMessage() Removes the head of the message queue
protected ActorMessage	SequentialProcessingActor.takeMessage() Takes a message from the queues.
protected ActorMessage	SequentialProcessingActor.takeMessage(long timeout, java.util.concurrent.TimeUnit timeUnit) Takes a message from the queues.

Methods in groovyx.gpars.actor.impl with parameters of type ActorMessage

Modifier and Type	Method and Description
private void	SequentialProcessingActor.throwIfNeeded(ActorMessage toProcess) Checks the supplied message and throws either STOP or TERMINATE, if the message is a Stop or Terminate message respectively.

Constructors in groovyx.gpars.actor.impl with parameters of type ActorMessage

Constructor and Description
MessageStream.SendTo(MessageStream to, ActorMessage message)
SequentialProcessingActor.Node(ActorMessage actorMessage)