groovyx.gpars.actor.impl
Class ReplyingMessageStream

java.lang.Object
  groovyx.gpars.serial.WithSerialId
      groovyx.gpars.actor.impl.MessageStream
          groovyx.gpars.actor.Actor
              groovyx.gpars.actor.impl.ReplyingMessageStream

All Implemented Interfaces:

java.io.Serializable

Direct Known Subclasses:

SequentialProcessingActor

public abstract class ReplyingMessageStream
extends Actor

Author:

Alex Tkachman, Vaclav Pech

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class groovyx.gpars.actor.Actor

Actor.MyRemoteHandle, Actor.RemoteActor

Nested classes/interfaces inherited from class groovyx.gpars.actor.impl.MessageStream

MessageStream.RemoteMessageStream, MessageStream.SendTo

Field Summary

protected java.util.WeakHashMap<java.lang.Object,MessageStream>	obj2Sender
private java.util.List<MessageStream>	senders A list of senders for the currently processed messages
private static long	serialVersionUID

Fields inherited from class groovyx.gpars.actor.Actor

ACTOR_HAS_ALREADY_BEEN_STARTED, currentThread, parallelGroup, START_MESSAGE, STOP_MESSAGE, TERMINATE_MESSAGE, TIMEOUT, TIMEOUT_MESSAGE, timer

Fields inherited from class groovyx.gpars.serial.WithSerialId

serialHandle

Constructor Summary

ReplyingMessageStream()

Method Summary

protected MessageStream	getSender() Retrieves the sender actor of the currently processed message.
protected java.util.List<MessageStream>	getSenders()
protected void	reply(java.lang.Object message) Sends a reply to all currently processed messages.
protected void	replyIfExists(java.lang.Object message) Sends a reply to all currently processed messages, which have been sent by an actor.
protected void	runEnhancedWithRepliesOnMessages(ActorMessage message, groovy.lang.Closure code)

Methods inherited from class groovyx.gpars.actor.Actor

createActorMessage, createRemoteHandle, deregisterCurrentActorWithThread, getJoinLatch, getParallelGroup, handleException, handleInterrupt, handleStart, handleTermination, handleTimeout, hasBeenStopped, isActive, isActorThread, join, join, join, join, onStop, registerCurrentActorWithThread, sendAndContinue, setParallelGroup, silentStart, start, stop, sweepNextMessage, terminate, threadBoundActor

Methods inherited from class groovyx.gpars.actor.impl.MessageStream

call, getRemoteClass, leftShift, reInterrupt, send, send, send, sendAndWait, sendAndWait, sendAndWait

Methods inherited from class groovyx.gpars.serial.WithSerialId

getOrCreateSerialHandle, writeReplace

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

serialVersionUID

private static final long serialVersionUID

See Also:

Constant Field Values

senders

private final java.util.List<MessageStream> senders

A list of senders for the currently processed messages

obj2Sender

protected final java.util.WeakHashMap<java.lang.Object,MessageStream> obj2Sender

Constructor Detail

ReplyingMessageStream

public ReplyingMessageStream()

Method Detail

getSenders

protected final java.util.List<MessageStream> getSenders()

getSender

protected final MessageStream getSender()

Retrieves the sender actor of the currently processed message.

Returns:

The sender of the currently processed message or null, if the message was not sent by an actor

Throws:

ActorReplyException - If some of the replies failed to be sent.

reply

protected final void reply(java.lang.Object message)

Sends a reply to all currently processed messages. Throws ActorReplyException if some messages have not been sent by an actor. For such cases use replyIfExists().

Parameters:

message - reply message

Throws:

ActorReplyException - If some of the replies failed to be sent.

replyIfExists

protected final void replyIfExists(java.lang.Object message)

Sends a reply to all currently processed messages, which have been sent by an actor. Ignores potential errors when sending the replies, like no sender or sender already stopped.

Parameters:

message - reply message

runEnhancedWithRepliesOnMessages

protected final void runEnhancedWithRepliesOnMessages(ActorMessage message,
                                                      groovy.lang.Closure code)