OpflowRpcWorker (opflow-core 0.1.4 API)

public class OpflowRpcWorker
extends Object

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

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

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`close()`
`OpflowBroker.ConsumerInfo`	`process(OpflowRpcListener listener)`
`OpflowBroker.ConsumerInfo`	`process(OpflowRpcWorker.Checker checker, OpflowRpcListener listener)`
`OpflowBroker.ConsumerInfo`	`process(String[] routineIds, OpflowRpcListener listener)`
`OpflowBroker.ConsumerInfo`	`process(String routineId, OpflowRpcListener listener)`

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

public OpflowBroker.ConsumerInfo process(OpflowRpcListener listener)

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

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

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

Class OpflowRpcWorker