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)#