Overview  Package   Class  Deprecated  Index  Help 
org.codehaus.gpars
FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

groovyx.gpars.actor.impl
[Java] Class ReplyingMessageStream

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

@java.lang.SuppressWarnings}
public abstract class ReplyingMessageStream
extends Actor

Authors:
Alex Tkachman, Vaclav Pech

Field Summary
private MessageStream sender

private static long serialVersionUID

 
Fields inherited from class Actor
ACTOR_HAS_ALREADY_BEEN_STARTED, AFTER_START, CANNOT_SEND_REPLIES_NO_SENDER_HAS_BEEN_REGISTERED, EMPTY_ARGUMENTS, ON_DELIVERY_ERROR, RESPONDS_TO, START_MESSAGE, STOP_MESSAGE, TERMINATE_MESSAGE, TIMEOUT, TIMEOUT_MESSAGE, currentActorPerThread, currentThread, joinLatch, onStop, parallelGroup, serialVersionUID, timer
 
Fields inherited from class MessageStream
serialVersionUID
 
Fields inherited from class WithSerialId
serialHandle, serialVersionUID
 
Constructor Summary
ReplyingMessageStream()

 
Method Summary
protected MessageStream getSender()

protected void reply(java.lang.Object message)

protected void replyIfExists(java.lang.Object message)

protected void setSender(MessageStream sender)

 
Methods inherited from class Actor
callDynamic, createActorMessage, createRemoteHandle, deregisterCurrentActorWithThread, getJoinLatch, getParallelGroup, handleException, handleInterrupt, handleStart, handleTermination, handleTimeout, hasBeenStopped, isActive, isActorThread, join, join, join, join, onStop, registerCurrentActorWithThread, sendAndContinue, sendAndPromise, setParallelGroup, silentStart, start, stop, sweepNextMessage, sweepQueue, terminate, threadBoundActor
 
Methods inherited from class MessageStream
call, getRemoteClass, leftShift, reInterrupt, send, send, send, sendAndWait, sendAndWait, sendAndWait
 
Methods inherited from class WithSerialId
createRemoteHandle, getOrCreateSerialHandle, getRemoteClass, writeReplace
 

Field Detail

sender

private MessageStream sender

serialVersionUID

private static final long serialVersionUID

 
Constructor Detail

ReplyingMessageStream

ReplyingMessageStream()

 
Method Detail

getSender

@java.lang.SuppressWarnings*          If some of the replies failed to be sent.
protected final MessageStream getSender()

reply

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

replyIfExists

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

setSender

protected final void setSender(MessageStream sender)

 

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