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

A

acquireChannel(OpflowEngine.Operator) - Method in class com.devebot.opflow.OpflowEngine

addRpcListener(String, OpflowRpcListener) - Method in class com.devebot.opflow.OpflowServerlet.DescriptorBuilder

addStringifyInterceptor(OpflowLogTracer.StringifyInterceptor) - Static method in class com.devebot.opflow.OpflowLogTracer

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

assertQueue(String) - Method in class com.devebot.opflow.OpflowExecutor

B

bingo() - Method in class com.devebot.opflow.OpflowTask.Countdown

branch(String, Object) - Method in class com.devebot.opflow.OpflowLogTracer

build() - Method in class com.devebot.opflow.OpflowServerlet.DescriptorBuilder

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

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

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

C

cancelConsumer(OpflowEngine.ConsumerInfo) - Method in class com.devebot.opflow.OpflowEngine

check() - Method in class com.devebot.opflow.OpflowEngine

check() - Method in class com.devebot.opflow.OpflowPubsubHandler

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

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

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

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

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

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

Close this broker.

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

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

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

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

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

CONNECTION_CLOSED - Static variable in class com.devebot.opflow.OpflowEngine.State

CONNECTION_NEW - Static variable in class com.devebot.opflow.OpflowEngine.State

CONNECTION_OPENED - Static variable in class com.devebot.opflow.OpflowEngine.State

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

ConsumerInfo(Connection, boolean, Channel, boolean, String, boolean, String, String) - Constructor for class com.devebot.opflow.OpflowEngine.ConsumerInfo

copy() - Method in class com.devebot.opflow.OpflowLogTracer

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

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

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

Countdown(int, long) - Constructor for class com.devebot.opflow.OpflowTask.Countdown

countQueue(String) - Method in class com.devebot.opflow.OpflowExecutor

createCommander() - Static method in class com.devebot.opflow.OpflowBuilder

createCommander(String) - Static method in class com.devebot.opflow.OpflowBuilder

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

createCommander(Map<String, Object>, String, boolean) - Static method in class com.devebot.opflow.OpflowBuilder

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

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

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

createPubsubHandler(Map<String, Object>, String, boolean) - Static method in class com.devebot.opflow.OpflowBuilder

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

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

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

createRpcMaster(Map<String, Object>, String, boolean) - Static method in class com.devebot.opflow.OpflowBuilder

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

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

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

createRpcWorker(Map<String, Object>, String, boolean) - Static method in class com.devebot.opflow.OpflowBuilder

createServerlet() - Static method in class com.devebot.opflow.OpflowBuilder

createServerlet(String) - Static method in class com.devebot.opflow.OpflowBuilder

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

createServerlet(Map<String, Object>, String, boolean) - Static method in class com.devebot.opflow.OpflowBuilder

createServerlet(OpflowServerlet.ListenerDescriptor) - Static method in class com.devebot.opflow.OpflowBuilder

createServerlet(OpflowServerlet.ListenerDescriptor, String) - Static method in class com.devebot.opflow.OpflowBuilder

createServerlet(OpflowServerlet.ListenerDescriptor, Map<String, Object>) - Static method in class com.devebot.opflow.OpflowBuilder

createServerlet(OpflowServerlet.ListenerDescriptor, Map<String, Object>, String, boolean) - Static method in class com.devebot.opflow.OpflowBuilder

D

DEFAULT_CONFIGURATION_ENV - Static variable in class com.devebot.opflow.OpflowBuilder

DEFAULT_CONFIGURATION_FILE - Static variable in class com.devebot.opflow.OpflowBuilder

DEFAULT_CONFIGURATION_KEY - Static variable in class com.devebot.opflow.OpflowBuilder

defineExchange(String, String) - Method in class com.devebot.opflow.OpflowExecutor

defineQueue(String) - Method in class com.devebot.opflow.OpflowExecutor

deleteExchange(String) - Method in class com.devebot.opflow.OpflowExecutor

deleteQueue(String) - Method in class com.devebot.opflow.OpflowExecutor

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

EMPTY - Static variable in class com.devebot.opflow.OpflowServerlet.ListenerDescriptor

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

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

extractField(String, String, Class<T>) - Static method in class com.devebot.opflow.OpflowJsontool

extractFieldAsInt(String, String) - Static method in class com.devebot.opflow.OpflowJsontool

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

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

G

get(String) - Method in class com.devebot.opflow.OpflowLogTracer

get(String) - Method in class com.devebot.opflow.OpflowUtil.MapBuilder

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

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

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

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

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

getConfigurationExtension(URL) - Static method in class com.devebot.opflow.OpflowBuilder

getConfigurer() - Method in class com.devebot.opflow.OpflowServerlet.ListenerDescriptor

getConnection() - Method in class com.devebot.opflow.OpflowEngine.ConsumerInfo

getConnectionState() - Method in class com.devebot.opflow.OpflowEngine.State

getConsumerId() - Method in class com.devebot.opflow.OpflowEngine.ConsumerInfo

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

getCount() - Method in class com.devebot.opflow.OpflowTask.Countdown

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

getDescriptorBuilder() - Static method in class com.devebot.opflow.OpflowServerlet

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

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

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

getExecutor() - Method in class com.devebot.opflow.OpflowPubsubHandler

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

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

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

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

getLibraryInfo() - Static method in class com.devebot.opflow.OpflowLogTracer

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

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

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

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

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

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

getOptionField(Map<String, Object>, String, Object) - 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.OpflowEngine.ConsumerInfo

getRecyclebinName() - Method in class com.devebot.opflow.OpflowPubsubHandler

getRedeliveredLimit() - Method in class com.devebot.opflow.OpflowPubsubHandler

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

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

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

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

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

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

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

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

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

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

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

getRpcListeners() - Method in class com.devebot.opflow.OpflowServerlet.ListenerDescriptor

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

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

getSubscriber() - Method in class com.devebot.opflow.OpflowServerlet.ListenerDescriptor

getSubscriberName() - Method in class com.devebot.opflow.OpflowPubsubHandler

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

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

getTimeout() - Method in interface com.devebot.opflow.OpflowTask.Timeoutable

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

getTimestamp() - Method in interface com.devebot.opflow.OpflowTask.Timeoutable

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(Channel) - Method in interface com.devebot.opflow.OpflowEngine.Operator

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

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

I

instantiateType(Class) - Method in class com.devebot.opflow.OpflowServerlet

instantiateType(Class) - Method in class com.devebot.opflow.OpflowServerlet.Instantiator

instantiateTypes(Class[]) - Method in class com.devebot.opflow.OpflowServerlet.Instantiator

instantiateTypes(Collection<Class>) - Method in class com.devebot.opflow.OpflowServerlet.Instantiator

Instantiator(OpflowRpcWorker) - Constructor for class com.devebot.opflow.OpflowServerlet.Instantiator

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

intercept(Map<String, Object>) - Method in interface com.devebot.opflow.OpflowLogTracer.StringifyInterceptor

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

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

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

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

isSharedChannel() - Method in class com.devebot.opflow.OpflowEngine.ConsumerInfo

isSharedConnection() - Method in class com.devebot.opflow.OpflowEngine.ConsumerInfo

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

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

J

jsonExtractField(String, String, Class<T>) - Static method in class com.devebot.opflow.OpflowUtil

Deprecated.

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

Deprecated.

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

Deprecated.

jsonMessageToObject(OpflowMessage, Class<T>) - Static method in class com.devebot.opflow.OpflowUtil

Deprecated.

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

Deprecated.

jsonStringToArray(String, Class[]) - Static method in class com.devebot.opflow.OpflowUtil

Deprecated.

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

Deprecated.

jsonStringToObject(String, Class<T>) - Static method in class com.devebot.opflow.OpflowUtil

Deprecated.

L

loadConfiguration() - Static method in class com.devebot.opflow.OpflowBuilder

loadConfiguration(String) - Static method in class com.devebot.opflow.OpflowBuilder

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

loadConfiguration(Map<String, Object>, String, boolean) - Static method in class com.devebot.opflow.OpflowBuilder

loadProperties() - Static method in class com.devebot.opflow.OpflowBuilder

M

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

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

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

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

mergeConfiguration(Map<String, Object>, Properties) - Static method in class com.devebot.opflow.OpflowBuilder

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

OpflowBootstrapException - Exception in com.devebot.opflow.exception

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

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

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

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

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

OpflowBuilder - Class in com.devebot.opflow

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

OpflowCommander - Class in com.devebot.opflow

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

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

OpflowConnectionException - Exception in com.devebot.opflow.exception

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

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

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

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

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

OpflowConsumerOverLimitException - Exception in com.devebot.opflow.exception

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

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

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

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

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

OpflowEngine - Class in com.devebot.opflow

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

OpflowEngine.ConsumerInfo - Class in com.devebot.opflow

OpflowEngine.Operator - Interface in com.devebot.opflow

OpflowEngine.State - Class in com.devebot.opflow

OpflowExecutor - Class in com.devebot.opflow

OpflowExecutor(OpflowEngine) - Constructor for class com.devebot.opflow.OpflowExecutor

OpflowHelper - Class in com.devebot.opflow

Deprecated.

As of release 0.1.12, replaced by OpflowBuilder

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

Deprecated.

OpflowInterceptionException - Exception in com.devebot.opflow.exception

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

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

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

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

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

OpflowJsontool - Class in com.devebot.opflow

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

OpflowJsonTransformationException - Exception in com.devebot.opflow.exception

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

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

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

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

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

OpflowListener - Interface in com.devebot.opflow

OpflowLogTracer - Class in com.devebot.opflow

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

OpflowLogTracer.StringifyInterceptor - 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

OpflowPubsubHandler.State - Class in com.devebot.opflow

OpflowPubsubListener - Interface in com.devebot.opflow

OpflowRequestFailureException - Exception in com.devebot.opflow.exception

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

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

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

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

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

OpflowRequestTimeoutException - Exception in com.devebot.opflow.exception

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

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

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

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

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

OpflowRestrictedTestingException - Exception in com.devebot.opflow.exception

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

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

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

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

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

OpflowRpcListener - Interface in com.devebot.opflow

OpflowRpcMaster - Class in com.devebot.opflow

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

OpflowRpcMaster.State - Class in com.devebot.opflow

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, String, String, List<OpflowRpcResult.Step>, boolean, byte[], boolean, 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

OpflowRpcWorker.State - Class in com.devebot.opflow

OpflowServerlet - Class in com.devebot.opflow

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

OpflowServerlet.DescriptorBuilder - Class in com.devebot.opflow

OpflowServerlet.Instantiator - Class in com.devebot.opflow

OpflowServerlet.ListenerDescriptor - Class in com.devebot.opflow

OpflowTask - Class in com.devebot.opflow

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

OpflowTask.Countdown - Class in com.devebot.opflow

OpflowTask.Listener - Interface in com.devebot.opflow

OpflowTask.Timeoutable - 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.MapBuilder - Class in com.devebot.opflow

OpflowUtil.MapListener - Interface in com.devebot.opflow

P

PARAMETER_NAMES - Static variable in class com.devebot.opflow.OpflowEngine

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(Set<String>, OpflowRpcListener) - Method in class com.devebot.opflow.OpflowRpcWorker

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

process() - Method in class com.devebot.opflow.OpflowServerlet.Instantiator

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[], Map<String, Object>) - Method in class com.devebot.opflow.OpflowEngine

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

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

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

publish(String) - Method in class com.devebot.opflow.OpflowPubsubHandler

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

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

publish(byte[]) - Method in class com.devebot.opflow.OpflowPubsubHandler

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

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

purgeQueue(String) - Method in class com.devebot.opflow.OpflowExecutor

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

put(String, Object) - Method in class com.devebot.opflow.OpflowLogTracer

put(String, Object) - Method in class com.devebot.opflow.OpflowUtil.MapBuilder

R

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

raiseTimeout() - Method in interface com.devebot.opflow.OpflowTask.Timeoutable

registerType(Class<T>) - Method in class com.devebot.opflow.OpflowCommander

removeStringifyInterceptor(OpflowLogTracer.StringifyInterceptor) - Static method in class com.devebot.opflow.OpflowLogTracer

request(String, String) - Method in class com.devebot.opflow.OpflowRpcMaster

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

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

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

reset(int) - Method in class com.devebot.opflow.OpflowLogTracer

reset() - Method in class com.devebot.opflow.OpflowLogTracer

reset(int) - Method in class com.devebot.opflow.OpflowTask.Countdown

reset(int, long) - Method in class com.devebot.opflow.OpflowTask.Countdown

ROOT - Static variable in class com.devebot.opflow.OpflowLogTracer

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

S

setConfigurer(OpflowPubsubListener) - Method in class com.devebot.opflow.OpflowServerlet.DescriptorBuilder

setSubscriber(OpflowPubsubListener) - Method in class com.devebot.opflow.OpflowServerlet.DescriptorBuilder

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

start() - Method in class com.devebot.opflow.OpflowServerlet

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

State(OpflowEngine.State) - Constructor for class com.devebot.opflow.OpflowEngine.State

State(OpflowEngine.State) - Constructor for class com.devebot.opflow.OpflowPubsubHandler.State

State(OpflowEngine.State) - Constructor for class com.devebot.opflow.OpflowRpcMaster.State

State(OpflowEngine.State) - Constructor for class com.devebot.opflow.OpflowRpcWorker.State

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

stringify() - Method in class com.devebot.opflow.OpflowLogTracer

stringify(boolean) - Method in class com.devebot.opflow.OpflowLogTracer

stringify(boolean, int) - Method in class com.devebot.opflow.OpflowLogTracer

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

T

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

TimeoutMonitor(Map<String, ? extends OpflowTask.Timeoutable>, int) - Constructor for class com.devebot.opflow.OpflowTask.TimeoutMonitor

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

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

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

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

toMap() - Method in class com.devebot.opflow.OpflowUtil.MapBuilder

toObject(String, Class<T>) - Static method in class com.devebot.opflow.OpflowJsontool

toObject(OpflowMessage, Class<T>) - Static method in class com.devebot.opflow.OpflowJsontool

toObjectArray(String, Class[]) - Static method in class com.devebot.opflow.OpflowJsontool

toObjectMap(String) - Static method in class com.devebot.opflow.OpflowJsontool

toString(Object) - Static method in class com.devebot.opflow.OpflowJsontool

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

toString() - Method in class com.devebot.opflow.OpflowLogTracer

toString() - Method in class com.devebot.opflow.OpflowUtil.MapBuilder

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

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

truncate(String, int) - Static method in class com.devebot.opflow.OpflowUtil

U

unregisterType(Class<T>) - Method in class com.devebot.opflow.OpflowCommander

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