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

groovyx.gpars.dataflow.operator
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

class DataFlowProcessorActor
extends DynamicDispatchActor
Field Summary
 
Fields inherited from class Actor
ACTOR_HAS_ALREADY_BEEN_STARTED, START_MESSAGE, STOP_MESSAGE, TERMINATE_MESSAGE, TIMEOUT_MESSAGE, currentThread, parallelGroup, timer
 
Property Summary
protected groovy.lang.Closure code

protected java.util.List inputs

protected java.util.List outputs

protected java.lang.Object owningProcessor

 
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 checkPoisson(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
when
 
Methods inherited from class AbstractLoopingActor
getCore, getSender, hasBeenStopped, initialize, isActive, isFair, makeFair, reply, replyIfExists, send, setParallelGroup, setTimeout, silentStart, start, stop, sweepNextMessage, terminate
 
Methods inherited from class 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, 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
 

Property 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

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

 
Method Detail

checkPoisson

boolean checkPoisson(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

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

send

@Override
public 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.