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

groovyx.gpars.dataflow.operator
[Groovy] Class DataflowProcessorActor

java.lang.Object
  groovyx.gpars.serial.WithSerialId
      groovyx.gpars.actor.impl.MessageStream
          groovyx.gpars.actor.Actor
              groovyx.gpars.actor.AbstractLoopingActor
                  groovyx.gpars.actor.DynamicDispatchActor
                      groovyx.gpars.dataflow.operator.DataflowProcessorActor

protected abstract class DataflowProcessorActor
extends DynamicDispatchActor
Field Summary
protected groovy.lang.Closure code

protected java.util.List inputs

protected java.util.List outputs

protected java.lang.Object owningProcessor

 
Fields inherited from class DynamicDispatchActor
serialVersionUID
 
Fields inherited from class AbstractLoopingActor
core, currentSender, currentTimerTask, serialVersionUID, stoppedFlag, terminatedFlag, terminatingFlag, timeoutCounter
 
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
DataflowProcessorActor(java.lang.Object owningProcessor, java.lang.Object group, java.lang.Object outputs, java.lang.Object inputs, java.lang.Object code)

 
Method Summary
boolean checkPoison(java.lang.Object data)

Handles the poisson message.

void onMessage(java.lang.Object message)

All messages unhandled by sub-classes will result in an exception being thrown
java.lang.Object reportException(java.lang.Throwable e)

MessageStream send(java.lang.Object message)

Sends the message, ignoring exceptions caused by the actor not being active anymore
 
Methods inherited from class DynamicDispatchActor
become, when
 
Methods inherited from class AbstractLoopingActor
cancelCurrentTimeoutTask, doStart, getCore, getSender, hasBeenStopped, initialize, isActive, isFair, makeFair, reply, replyIfExists, runEnhancedWithoutRepliesOnMessages, send, setParallelGroup, setTimeout, silentStart, start, stop, sweepNextMessage, terminate
 
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, 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
 
Methods inherited from class java.lang.Object
java.lang.Object#wait(long), java.lang.Object#wait(), java.lang.Object#wait(long, int), 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()
 

Field Detail

code

protected final groovy.lang.Closure code

inputs

protected final java.util.List inputs

outputs

protected final java.util.List outputs

owningProcessor

protected final java.lang.Object owningProcessor

 
Constructor Detail

DataflowProcessorActor

DataflowProcessorActor(java.lang.Object owningProcessor, java.lang.Object group, java.lang.Object outputs, java.lang.Object inputs, java.lang.Object code)

 
Method Detail

checkPoison

boolean checkPoison(java.lang.Object data)
Handles the poisson message. After receiving the poisson a dataflow operator will send the poisson to all its output channels and terminate.
Parameters:
poisson - The poisson to re-send return True, if poisson has been received

onMessage

void onMessage(java.lang.Object message)
All messages unhandled by sub-classes will result in an exception being thrown
Parameters:
message - The unhandled message

reportException

final java.lang.Object reportException(java.lang.Throwable e)

send

@Override
MessageStream send(java.lang.Object message)
Sends the message, ignoring exceptions caused by the actor not being active anymore
Parameters:
message - The message to send
Returns:
The current actor

 

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