OpflowEngine.ConsumerInfo |
OpflowEngine.consume(OpflowEngine.Listener listener,
Map<String,Object> options) |
|
OpflowEngine.ConsumerInfo |
OpflowRpcAmqpWorker.process(OpflowRpcAmqpWorker.Checker checker,
OpflowRpcAmqpWorker.Listener listener) |
|
OpflowEngine.ConsumerInfo |
OpflowRpcAmqpWorker.process(OpflowRpcAmqpWorker.Listener listener) |
|
OpflowEngine.ConsumerInfo |
OpflowRpcAmqpWorker.process(String[] routineSignatures,
OpflowRpcAmqpWorker.Listener listener) |
|
OpflowEngine.ConsumerInfo |
OpflowRpcAmqpWorker.process(String routineSignature,
OpflowRpcAmqpWorker.Listener listener) |
|
OpflowEngine.ConsumerInfo |
OpflowRpcAmqpWorker.process(Set<String> routineSignatures,
OpflowRpcAmqpWorker.Listener listener) |
|
OpflowEngine.ConsumerInfo |
OpflowPubsubHandler.subscribe(OpflowPubsubListener newListener) |
|