OpflowRpcWorker (opflow-core 0.1.13 API)

public class OpflowRpcWorker
extends Object

Nested Classes
Modifier and Type	Class and Description
`static interface`	`OpflowRpcWorker.Checker`
`class`	`OpflowRpcWorker.Middleware`
`class`	`OpflowRpcWorker.State`

Constructors
Constructor and Description
`OpflowRpcWorker(Map<String,Object> params)`

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`OpflowRpcWorker.State`	`check()`
`void`	`close()`
`OpflowExecutor`	`getExecutor()`
`String`	`getOperatorName()`
`String`	`getResponseName()`
`OpflowEngine.ConsumerInfo`	`process(OpflowRpcListener listener)`
`OpflowEngine.ConsumerInfo`	`process(OpflowRpcWorker.Checker checker, OpflowRpcListener listener)`
`OpflowEngine.ConsumerInfo`	`process(String[] routineIds, OpflowRpcListener listener)`
`OpflowEngine.ConsumerInfo`	`process(String routineId, OpflowRpcListener listener)`

public OpflowRpcWorker(Map<String,Object> params)
                throws OpflowBootstrapException

public OpflowEngine.ConsumerInfo process(OpflowRpcListener listener)

public OpflowEngine.ConsumerInfo process(String routineId,
                                         OpflowRpcListener listener)

public OpflowEngine.ConsumerInfo process(String[] routineIds,
                                         OpflowRpcListener listener)

public OpflowEngine.ConsumerInfo process(OpflowRpcWorker.Checker checker,
                                         OpflowRpcListener listener)

Class OpflowRpcWorker