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 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
private  ActorMessage MessageStream.SendTo.message
           
(package private)  ActorMessage SequentialProcessingActor.Node.msg
           
 

Methods in groovyx.gpars.actor.impl that return ActorMessage
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
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
MessageStream.SendTo(MessageStream to, ActorMessage message)
           
SequentialProcessingActor.Node(ActorMessage actorMessage)
           
 


Copyright © 2008–2012 Václav Pech. All Rights Reserved.