A B C D E G H I M N O P R S T

A

arrayContains(T[], T) - Static method in class com.devebot.opflow.OpflowUtil

B

buildJson(OpflowUtil.MapListener) - Static method in class com.devebot.opflow.OpflowUtil

buildOptions(OpflowUtil.MapListener) - Static method in class com.devebot.opflow.OpflowUtil

buildOptions(OpflowUtil.MapListener, Map<String, Object>) - Static method in class com.devebot.opflow.OpflowUtil

C

check() - Method in class com.devebot.opflow.OpflowTask.TimeoutWatcher

cloneParameters(Map<String, Object>) - Static method in class com.devebot.opflow.OpflowUtil

close() - Method in class com.devebot.opflow.OpflowBroker

Close this broker.

close() - Method in class com.devebot.opflow.OpflowRpcMaster

close() - Method in class com.devebot.opflow.OpflowRpcWorker

close() - Method in class com.devebot.opflow.OpflowTask.TimeoutWatcher

com.devebot.opflow - package com.devebot.opflow

com.devebot.opflow.exception - package com.devebot.opflow.exception

consume(OpflowListener, Map<String, Object>) - Method in class com.devebot.opflow.OpflowBroker

ConsumerInfo(Channel, String, boolean, Consumer, String) - Constructor for class com.devebot.opflow.OpflowBroker.ConsumerInfo

createPubsubHandler() - Static method in class com.devebot.opflow.OpflowHelper

createPubsubHandler(String) - Static method in class com.devebot.opflow.OpflowHelper

createPubsubHandler(Properties) - Static method in class com.devebot.opflow.OpflowHelper

createPubsubHandler(String, Properties) - Static method in class com.devebot.opflow.OpflowHelper

createRpcMaster() - Static method in class com.devebot.opflow.OpflowHelper

createRpcMaster(String) - Static method in class com.devebot.opflow.OpflowHelper

createRpcMaster(Properties) - Static method in class com.devebot.opflow.OpflowHelper

createRpcMaster(String, Properties) - Static method in class com.devebot.opflow.OpflowHelper

createRpcWorker() - Static method in class com.devebot.opflow.OpflowHelper

createRpcWorker(String) - Static method in class com.devebot.opflow.OpflowHelper

createRpcWorker(Properties) - Static method in class com.devebot.opflow.OpflowHelper

createRpcWorker(String, Properties) - Static method in class com.devebot.opflow.OpflowHelper

D

DONE - Static variable in interface com.devebot.opflow.OpflowRpcListener

E

emitCompleted(String) - Method in class com.devebot.opflow.OpflowRpcResponse

emitCompleted(byte[]) - Method in class com.devebot.opflow.OpflowRpcResponse

emitFailed(String) - Method in class com.devebot.opflow.OpflowRpcResponse

emitFailed(byte[]) - Method in class com.devebot.opflow.OpflowRpcResponse

emitProgress(int, int) - Method in class com.devebot.opflow.OpflowRpcResponse

emitProgress(int, int, String) - Method in class com.devebot.opflow.OpflowRpcResponse

emitStarted() - Method in class com.devebot.opflow.OpflowRpcResponse

emitStarted(String) - Method in class com.devebot.opflow.OpflowRpcResponse

emitStarted(byte[]) - Method in class com.devebot.opflow.OpflowRpcResponse

EMPTY - Static variable in class com.devebot.opflow.OpflowMessage

ensureNotNull(Map<String, Object>) - Static method in class com.devebot.opflow.OpflowUtil

ERROR - Static variable in class com.devebot.opflow.OpflowMessage

exhaustRequest(OpflowRpcRequest) - Static method in class com.devebot.opflow.OpflowUtil

exhaustRequest(OpflowRpcRequest, boolean) - Static method in class com.devebot.opflow.OpflowUtil

exit() - Method in class com.devebot.opflow.OpflowRpcRequest

exit(boolean) - Method in class com.devebot.opflow.OpflowRpcRequest

G

getBytes(String) - Static method in class com.devebot.opflow.OpflowUtil

getChannel() - Method in class com.devebot.opflow.OpflowBroker.ConsumerInfo

getChecker() - Method in class com.devebot.opflow.OpflowRpcWorker.Middleware

getConsumer() - Method in class com.devebot.opflow.OpflowBroker.ConsumerInfo

getConsumerTag() - Method in class com.devebot.opflow.OpflowBroker.ConsumerInfo

getContent() - Method in class com.devebot.opflow.OpflowMessage

getContentAsString() - Method in class com.devebot.opflow.OpflowMessage

getCurrentTime() - Static method in class com.devebot.opflow.OpflowUtil

getError() - Method in class com.devebot.opflow.OpflowRpcResult

getErrorAsString() - Method in class com.devebot.opflow.OpflowRpcResult

getHeaders(AMQP.BasicProperties) - Static method in class com.devebot.opflow.OpflowUtil

getInfo() - Method in class com.devebot.opflow.OpflowMessage

getInfo() - Method in class com.devebot.opflow.OpflowRpcResult.Step

getListener() - Method in class com.devebot.opflow.OpflowRpcWorker.Middleware

getMessageField(OpflowMessage, String) - Static method in class com.devebot.opflow.OpflowUtil

getPercent() - Method in class com.devebot.opflow.OpflowRpcResult.Step

getProgress() - Method in class com.devebot.opflow.OpflowRpcResult

getQueueName() - Method in class com.devebot.opflow.OpflowBroker.ConsumerInfo

getRequestId() - Method in class com.devebot.opflow.OpflowRpcRequest

getRequestID(Map<String, Object>) - Static method in class com.devebot.opflow.OpflowUtil

getRoutineId() - Method in class com.devebot.opflow.OpflowRpcRequest

getStatus(OpflowMessage) - Static method in class com.devebot.opflow.OpflowUtil

getString(byte[]) - Static method in class com.devebot.opflow.OpflowUtil

getTimeout() - Method in class com.devebot.opflow.OpflowRpcRequest

getTimestamp() - Method in class com.devebot.opflow.OpflowRpcRequest

getUUID() - Static method in class com.devebot.opflow.OpflowUtil

getValue() - Method in class com.devebot.opflow.OpflowRpcResult

getValueAsString() - Method in class com.devebot.opflow.OpflowRpcResult

getWorkerTag() - Method in class com.devebot.opflow.OpflowRpcResult

H

handleEvent() - Method in interface com.devebot.opflow.OpflowTask.Listener

hasNext() - Method in class com.devebot.opflow.OpflowRpcRequest

I

isCracked() - Method in class com.devebot.opflow.OpflowRpcResult.Step

isFixedQueue() - Method in class com.devebot.opflow.OpflowBroker.ConsumerInfo

iterateRequest(OpflowRpcRequest) - Static method in class com.devebot.opflow.OpflowUtil

M

match(String) - Method in interface com.devebot.opflow.OpflowRpcWorker.Checker

Middleware(OpflowRpcWorker.Checker, OpflowRpcListener) - Constructor for class com.devebot.opflow.OpflowRpcWorker.Middleware

N

NEXT - Static variable in interface com.devebot.opflow.OpflowRpcListener

next() - Method in class com.devebot.opflow.OpflowRpcRequest

O

OpflowBroker - Class in com.devebot.opflow

OpflowBroker(Map<String, Object>) - Constructor for class com.devebot.opflow.OpflowBroker

OpflowBroker.ConsumerInfo - Class in com.devebot.opflow

OpflowConstructorException - Exception in com.devebot.opflow.exception

OpflowConstructorException() - Constructor for exception com.devebot.opflow.exception.OpflowConstructorException

OpflowConstructorException(String) - Constructor for exception com.devebot.opflow.exception.OpflowConstructorException

OpflowConstructorException(String, Throwable) - Constructor for exception com.devebot.opflow.exception.OpflowConstructorException

OpflowConstructorException(Throwable) - Constructor for exception com.devebot.opflow.exception.OpflowConstructorException

OpflowConstructorException(String, Throwable, boolean, boolean) - Constructor for exception com.devebot.opflow.exception.OpflowConstructorException

OpflowConsumerLimitExceedException - Exception in com.devebot.opflow.exception

OpflowConsumerLimitExceedException() - Constructor for exception com.devebot.opflow.exception.OpflowConsumerLimitExceedException

OpflowConsumerLimitExceedException(String) - Constructor for exception com.devebot.opflow.exception.OpflowConsumerLimitExceedException

OpflowConsumerLimitExceedException(String, Throwable) - Constructor for exception com.devebot.opflow.exception.OpflowConsumerLimitExceedException

OpflowConsumerLimitExceedException(Throwable) - Constructor for exception com.devebot.opflow.exception.OpflowConsumerLimitExceedException

OpflowConsumerLimitExceedException(String, Throwable, boolean, boolean) - Constructor for exception com.devebot.opflow.exception.OpflowConsumerLimitExceedException

OpflowHelper - Class in com.devebot.opflow

OpflowHelper() - Constructor for class com.devebot.opflow.OpflowHelper

OpflowListener - Interface in com.devebot.opflow

OpflowMessage - Class in com.devebot.opflow

OpflowMessage(byte[], Map<String, Object>) - Constructor for class com.devebot.opflow.OpflowMessage

OpflowOperationException - Exception in com.devebot.opflow.exception

OpflowOperationException() - Constructor for exception com.devebot.opflow.exception.OpflowOperationException

OpflowOperationException(String) - Constructor for exception com.devebot.opflow.exception.OpflowOperationException

OpflowOperationException(String, Throwable) - Constructor for exception com.devebot.opflow.exception.OpflowOperationException

OpflowOperationException(Throwable) - Constructor for exception com.devebot.opflow.exception.OpflowOperationException

OpflowOperationException(String, Throwable, boolean, boolean) - Constructor for exception com.devebot.opflow.exception.OpflowOperationException

OpflowPubsubHandler - Class in com.devebot.opflow

OpflowPubsubHandler(Map<String, Object>) - Constructor for class com.devebot.opflow.OpflowPubsubHandler

OpflowPubsubListener - Interface in com.devebot.opflow

OpflowRpcListener - Interface in com.devebot.opflow

OpflowRpcMaster - Class in com.devebot.opflow

OpflowRpcMaster(Map<String, Object>) - Constructor for class com.devebot.opflow.OpflowRpcMaster

OpflowRpcRequest - Class in com.devebot.opflow

OpflowRpcRequest(Map<String, Object>, OpflowTask.Listener) - Constructor for class com.devebot.opflow.OpflowRpcRequest

OpflowRpcResponse - Class in com.devebot.opflow

OpflowRpcResponse(Channel, AMQP.BasicProperties, String, String) - Constructor for class com.devebot.opflow.OpflowRpcResponse

OpflowRpcResult - Class in com.devebot.opflow

OpflowRpcResult(String, List<OpflowRpcResult.Step>, byte[], byte[]) - Constructor for class com.devebot.opflow.OpflowRpcResult

OpflowRpcResult.Step - Class in com.devebot.opflow

OpflowRpcWorker - Class in com.devebot.opflow

OpflowRpcWorker(Map<String, Object>) - Constructor for class com.devebot.opflow.OpflowRpcWorker

OpflowRpcWorker.Checker - Interface in com.devebot.opflow

OpflowRpcWorker.Middleware - Class in com.devebot.opflow

OpflowTask - Class in com.devebot.opflow

OpflowTask() - Constructor for class com.devebot.opflow.OpflowTask

OpflowTask.Listener - Interface in com.devebot.opflow

OpflowTask.TimeoutMonitor - Class in com.devebot.opflow

OpflowTask.TimeoutWatcher - Class in com.devebot.opflow

OpflowUtil - Class in com.devebot.opflow

OpflowUtil() - Constructor for class com.devebot.opflow.OpflowUtil

OpflowUtil.MapListener - Interface in com.devebot.opflow

P

process(OpflowRpcListener) - Method in class com.devebot.opflow.OpflowRpcWorker

process(String, OpflowRpcListener) - Method in class com.devebot.opflow.OpflowRpcWorker

process(String[], OpflowRpcListener) - Method in class com.devebot.opflow.OpflowRpcWorker

process(OpflowRpcWorker.Checker, OpflowRpcListener) - Method in class com.devebot.opflow.OpflowRpcWorker

processMessage(byte[], AMQP.BasicProperties, String, Channel, String) - Method in interface com.devebot.opflow.OpflowListener

processMessage(OpflowMessage) - Method in interface com.devebot.opflow.OpflowPubsubListener

processMessage(OpflowMessage, OpflowRpcResponse) - Method in interface com.devebot.opflow.OpflowRpcListener

produce(byte[], AMQP.BasicProperties, Map<String, Object>) - Method in class com.devebot.opflow.OpflowBroker

publish(String, Map<String, Object>, String) - Method in class com.devebot.opflow.OpflowPubsubHandler

publish(byte[], Map<String, Object>, String) - Method in class com.devebot.opflow.OpflowPubsubHandler

push(OpflowMessage) - Method in class com.devebot.opflow.OpflowRpcRequest

R

request(String, String, Map<String, Object>) - Method in class com.devebot.opflow.OpflowRpcMaster

request(String, byte[], Map<String, Object>) - Method in class com.devebot.opflow.OpflowRpcMaster

run() - Method in class com.devebot.opflow.OpflowTask.TimeoutWatcher

S

splitByComma(String) - Static method in class com.devebot.opflow.OpflowUtil

start() - Method in class com.devebot.opflow.OpflowTask.TimeoutMonitor

Step() - Constructor for class com.devebot.opflow.OpflowRpcResult.Step

Step(int) - Constructor for class com.devebot.opflow.OpflowRpcResult.Step

Step(int, String) - Constructor for class com.devebot.opflow.OpflowRpcResult.Step

stop() - Method in class com.devebot.opflow.OpflowTask.TimeoutMonitor

subscribe(OpflowPubsubListener) - Method in class com.devebot.opflow.OpflowPubsubHandler

T

TimeoutMonitor(Map<String, OpflowRpcRequest>) - Constructor for class com.devebot.opflow.OpflowTask.TimeoutMonitor

TimeoutMonitor(Map<String, OpflowRpcRequest>, int, long, String) - Constructor for class com.devebot.opflow.OpflowTask.TimeoutMonitor

TimeoutWatcher(long, OpflowTask.Listener) - Constructor for class com.devebot.opflow.OpflowTask.TimeoutWatcher

TimeoutWatcher(long, long, OpflowTask.Listener) - Constructor for class com.devebot.opflow.OpflowTask.TimeoutWatcher

transform(Map<String, Object>) - Method in interface com.devebot.opflow.OpflowUtil.MapListener

A B C D E G H I M N O P R S T