Field Summary

Fields 

Modifiers	Name	Description
protected static java.lang.String	CANNOT_OBTAIN_THE_SEMAPHORE_TO_FORK_OPERATOR_S_BODY
protected groovy.lang.Closure	code
protected java.util.List	inputs
protected java.util.List	outputs
protected DataflowProcessor	owningProcessor
protected boolean	stoppingGently

Inherited fields 

Fields inherited from class	Fields
class StaticDispatchActor	serialVersionUID
class AbstractLoopingActor	core, currentSender, currentTimerTask, serialVersionUID, stoppedFlag, terminatedFlag, terminatingFlag, timeoutCounter
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
class MessageStream	serialVersionUID
class WithSerialId	serialHandle, serialVersionUID

Constructor Summary

Constructors 

Constructor and description
DataflowProcessorActor (DataflowProcessor owningProcessor, PGroup group, java.util.List outputs, java.util.List inputs, groovy.lang.Closure code)

Methods Summary

Methods 

Type	Name and description
void	afterStart()
void	afterStop()
void	checkPoison(java.lang.Object data) Handles the poisson message.
protected java.lang.Object	fireMessageArrived(java.lang.Object result, int index, boolean controlMessage)
protected void	forwardPoisonPill(java.lang.Object data)
static boolean	isControlMessage(java.lang.Object message)
void	onException(java.lang.Throwable e)
void	onMessage(java.lang.Object message) All messages unhandled by sub-classes will result in an exception being thrown
void	registerChannelListenersToAllInputs(DataflowChannelListener<java.lang.Object> handler) Registers the provided handler to all input channels
void	reportException(java.lang.Throwable e)
MessageStream	send(java.lang.Object message) Sends the message, ignoring exceptions caused by the actor not being active anymore

Inherited Methods Summary

Inherited Methods 

Methods inherited from class	Name
class StaticDispatchActor	onMessage
class AbstractLoopingActor	cancelCurrentTimeoutTask, doStart, getCore, getSender, hasBeenStopped, initialize, isActive, isFair, makeFair, reply, replyIfExists, runEnhancedWithoutRepliesOnMessages, send, setParallelGroup, setTimeout, silentStart, start, stop, sweepNextMessage, terminate
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
class MessageStream	call, getRemoteClass, leftShift, reInterrupt, send, send, send, sendAndWait, sendAndWait, sendAndWait
class WithSerialId	createRemoteHandle, getOrCreateSerialHandle, getRemoteClass, writeReplace
class java.lang.Object	java.lang.Object#wait(), java.lang.Object#wait(long, int), java.lang.Object#wait(long), java.lang.Object#equals(java.lang.Object), java.lang.Object#toString(), java.lang.Object#hashCode(), java.lang.Object#getClass(), java.lang.Object#notify(), java.lang.Object#notifyAll()