Uses of Class
groovyx.gpars.actor.ActorMessage

Packages that use ActorMessage

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

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

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

(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

private java.lang.Object	AbstractPooledActor.enhanceAndUnwrap(ActorMessage message) Deprecated.
private void	AbstractLoopingActor.runEnhancedWithoutRepliesOnMessages(ActorMessage message, groovy.lang.Closure code, java.lang.Object arguments)

Method parameters in groovyx.gpars.actor with type arguments of type ActorMessage

private void	AbstractPooledActor.collectRequiredMessages(java.util.Collection<ActorMessage> messages, int toReceive) Deprecated.
private void	AbstractPooledActor.enhanceReplies(java.lang.Iterable<ActorMessage> messages) Deprecated. Adds reply and replyIfExists methods to the current Actor and the message.
private static java.lang.Object[]	AbstractPooledActor.retrievePayloadOfMessages(java.util.List<ActorMessage> messages) Deprecated.

Uses of ActorMessage in groovyx.gpars.actor.impl

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

private static ActorMessage	SequentialProcessingActor.loopMessage Deprecated.
private ActorMessage	MessageStream.SendTo.message
(package private) ActorMessage	SequentialProcessingActor.Node.msg
private static ActorMessage	SequentialProcessingActor.startMessage Deprecated.

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

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

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

void	SequentialProcessingActor.Reaction.offer(ActorMessage actorMessage)
protected void	ReplyingMessageStream.runEnhancedWithRepliesOnMessages(ActorMessage message, groovy.lang.Closure code)
(package private) void	SequentialProcessingActor.runReaction(ActorMessage message, groovy.lang.Closure code) Deprecated.
private void	SequentialProcessingActor.throwIfNeeded(ActorMessage toProcess) Deprecated. 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

MessageStream.SendTo(MessageStream to, ActorMessage message)

SequentialProcessingActor.Node(ActorMessage actorMessage)