class DataflowSelectorActor extends DataflowProcessorActor
Actor.MyRemoteHandle, Actor.RemoteActor
MessageStream.RemoteMessageStream, MessageStream.SendTo
Modifier and Type | Field and Description |
---|---|
protected boolean |
passIndex |
CANNOT_OBTAIN_THE_SEMAPHORE_TO_FORK_OPERATOR_S_BODY, code, inputs, outputs, owningProcessor, stoppingGently
ACTOR_HAS_ALREADY_BEEN_STARTED, CANNOT_SEND_REPLIES_NO_SENDER_HAS_BEEN_REGISTERED, currentThread, parallelGroup, START_MESSAGE, STOP_MESSAGE, TERMINATE_MESSAGE, TIMEOUT, TIMEOUT_MESSAGE, timer
serialHandle
Constructor and Description |
---|
DataflowSelectorActor(DataflowSelector owningOperator,
PGroup group,
java.util.List outputs,
java.util.List inputs,
groovy.lang.Closure code) |
Modifier and Type | Method and Description |
---|---|
(package private) void |
afterStart() |
void |
onMessage(java.lang.Object message)
All messages unhandled by sub-classes will result in an exception being thrown
|
(package private) void |
startTask(int index,
java.lang.Object result) |
afterStop, checkPoison, fireMessageArrived, forwardPoisonPill, isControlMessage, onException, reportException, send
getSender, hasBeenStopped, initialize, isActive, isFair, makeFair, reply, replyIfExists, setParallelGroup, setTimeout, silentStart, start, stop, sweepNextMessage, terminate
createActorMessage, createRemoteHandle, deregisterCurrentActorWithThread, getJoinLatch, getParallelGroup, handleException, handleInterrupt, handleStart, handleTermination, handleTimeout, isActorThread, join, join, join, join, onStop, registerCurrentActorWithThread, sendAndContinue, sendAndPromise, threadBoundActor
call, getRemoteClass, leftShift, send, send, sendAndWait, sendAndWait, sendAndWait
getOrCreateSerialHandle, writeReplace
DataflowSelectorActor(DataflowSelector owningOperator, PGroup group, java.util.List outputs, java.util.List inputs, groovy.lang.Closure code)
final void afterStart()
afterStart
in class DataflowProcessorActor
public final void onMessage(java.lang.Object message)
DataflowProcessorActor
onMessage
in class DataflowProcessorActor
message
- The unhandled messagevoid startTask(int index, java.lang.Object result)