OpflowEngine.ConsumerInfo |
OpflowEngine.consume(OpflowListener listener,
Map<String,Object> options) |
OpflowEngine.ConsumerInfo |
OpflowRpcWorker.process(OpflowRpcListener listener) |
OpflowEngine.ConsumerInfo |
OpflowRpcWorker.process(OpflowRpcWorker.Checker checker,
OpflowRpcListener listener) |
OpflowEngine.ConsumerInfo |
OpflowRpcWorker.process(String[] routineIds,
OpflowRpcListener listener) |
OpflowEngine.ConsumerInfo |
OpflowRpcWorker.process(String routineId,
OpflowRpcListener listener) |
OpflowEngine.ConsumerInfo |
OpflowPubsubHandler.subscribe(OpflowPubsubListener newListener) |