pypushflow.RouterActor.RouterActor¶

class pypushflow.RouterActor.RouterActor(parent=None, errorHandler=None, name='Router', itemName=None, listPort=None, **kw)[source]¶

Bases: AbstractActor

connect(actor, expectedValue='other')[source]¶

getActorPath()¶

hasFinished()¶

hasStarted()¶

property pool_resources¶

setFinished()¶

setMongoAttribute(attribute, value)¶

setStarted()¶

trigger(inData)[source]¶

uploadInDataToMongo(actorData=None, script=None)¶

uploadOutDataToMongo(actorData=None)¶