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