Index

A B C D E F G H I J L M N O P R S T U V W 
All Classes All Packages

A

acquireChannel(OpflowEngine.Operator) - Method in class com.devebot.opflow.OpflowEngine
 
addInterceptor(OpflowLogTracer.StringifyInterceptor) - Static method in class com.devebot.opflow.OpflowLogTracer
 
addRpcListener(String, OpflowRpcListener) - Method in class com.devebot.opflow.OpflowServerlet.DescriptorBuilder
 
alias() - Method in annotation type com.devebot.opflow.annotation.OpflowSourceRoutine
 
alias() - Method in annotation type com.devebot.opflow.annotation.OpflowTargetRoutine
 
ALL_BEAN_NAMES - Static variable in class com.devebot.opflow.OpflowCommander
 
arrayContains(T[], T) - Static method in class com.devebot.opflow.OpflowUtil
 
assertQueue(String) - Method in class com.devebot.opflow.OpflowExecutor
 
assertQueue(String, Boolean, Boolean, Boolean) - Method in class com.devebot.opflow.OpflowExecutor
 

B

bingo() - Method in class com.devebot.opflow.OpflowTimeout.Countdown
 
branch(String, Object) - Method in class com.devebot.opflow.OpflowLogTracer
 
branch(String, Object, OpflowLogTracer.Customizer) - 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
 
buildMap(OpflowUtil.MapListener, Map<String, Object>, boolean) - Static method in class com.devebot.opflow.OpflowUtil
 
buildMap(Map<String, Object>) - Static method in class com.devebot.opflow.OpflowUtil
 
buildOrderedMap() - Static method in class com.devebot.opflow.OpflowUtil
 
buildOrderedMap(OpflowUtil.MapListener) - Static method in class com.devebot.opflow.OpflowUtil
 
buildOrderedMap(OpflowUtil.MapListener, Map<String, Object>) - Static method in class com.devebot.opflow.OpflowUtil
 
buildOrderedMap(Map<String, Object>) - Static method in class com.devebot.opflow.OpflowUtil
 
buildResourceHandler(String) - Method in class com.devebot.opflow.OpflowRestServer
 
buildResourceHandler(String, int) - Method in class com.devebot.opflow.OpflowRestServer
 
buildSSLContext(String, String, KeyStore) - Static method in class com.devebot.opflow.supports.OpflowKeytool
 
buildSSLContextWithCertFile(String, String, String) - Static method in class com.devebot.opflow.supports.OpflowKeytool
 
buildSSLContextWithKeyStore(String, String, String, String) - Static method in class com.devebot.opflow.supports.OpflowKeytool
 

C

cancelConsumer(OpflowEngine.ConsumerInfo) - Method in class com.devebot.opflow.OpflowEngine
 
changeActiveChannel(String, String, OpflowPromMeasurer.GaugeAction) - Method in class com.devebot.opflow.OpflowPromExporter
 
changeActiveChannel(String, String, OpflowPromMeasurer.GaugeAction) - Method in class com.devebot.opflow.OpflowPromMeasurer
 
changeComponentInstance(String, String, OpflowPromMeasurer.GaugeAction) - Method in class com.devebot.opflow.OpflowPromExporter
 
changeComponentInstance(String, String, OpflowPromMeasurer.GaugeAction) - Method in class com.devebot.opflow.OpflowPromMeasurer
 
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.OpflowTimeout.Countdown
 
check() - Method in class com.devebot.opflow.OpflowTimeout.Watcher
 
clear() - Method in class com.devebot.opflow.OpflowLogTracer
 
clearInterceptors() - Static method in class com.devebot.opflow.OpflowLogTracer
 
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.OpflowRestServer
 
close() - Method in class com.devebot.opflow.OpflowRpcMaster
 
close() - Method in class com.devebot.opflow.OpflowRpcWatcher
 
close() - Method in class com.devebot.opflow.OpflowRpcWorker
 
close() - Method in class com.devebot.opflow.OpflowServerlet
 
close() - Method in class com.devebot.opflow.OpflowTimeout.Watcher
 
com.devebot.opflow - package com.devebot.opflow
 
com.devebot.opflow.annotation - package com.devebot.opflow.annotation
 
com.devebot.opflow.exception - package com.devebot.opflow.exception
 
com.devebot.opflow.supports - package com.devebot.opflow.supports
 
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
 
convert(Object, Class<T>) - Static method in class com.devebot.opflow.supports.OpflowConverter
 
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.OpflowTimeout.Countdown
 
Countdown(int) - Constructor for class com.devebot.opflow.OpflowTimeout.Countdown
 
Countdown(int, long) - Constructor for class com.devebot.opflow.OpflowTimeout.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(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
 
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
 

D

DEC - com.devebot.opflow.OpflowPromMeasurer.GaugeAction
 
decEngineConnectionGauge(ConnectionFactory, String) - Method in class com.devebot.opflow.OpflowPromExporter
 
decEngineConnectionGauge(ConnectionFactory, String) - Method in class com.devebot.opflow.OpflowPromMeasurer
 
DEFAULT_CONFIGURATION_ENV - Static variable in class com.devebot.opflow.OpflowConfig
 
DEFAULT_CONFIGURATION_FILE - Static variable in class com.devebot.opflow.OpflowConfig
 
DEFAULT_CONFIGURATION_KEY - Static variable in class com.devebot.opflow.OpflowConfig
 
DEFAULT_PROM_EXPORTER_PORT_ENV - Static variable in class com.devebot.opflow.OpflowPromMeasurer
 
DEFAULT_PROM_EXPORTER_PORT_KEY - Static variable in class com.devebot.opflow.OpflowPromMeasurer
 
DEFAULT_PROM_EXPORTER_PORT_VAL - Static variable in class com.devebot.opflow.OpflowPromMeasurer
 
DEFAULT_PROM_PUSHGATEWAY_ADDR_ENV - Static variable in class com.devebot.opflow.OpflowPromMeasurer
 
DEFAULT_PROM_PUSHGATEWAY_ADDR_KEY - Static variable in class com.devebot.opflow.OpflowPromMeasurer
 
DEFAULT_PROM_PUSHGATEWAY_ADDR_VAL - Static variable in class com.devebot.opflow.OpflowPromMeasurer
 
DEFAULT_PROM_PUSHGATEWAY_JOBNAME - Static variable in class com.devebot.opflow.OpflowPromMeasurer
 
defineExchange(String) - Method in class com.devebot.opflow.OpflowExecutor
 
defineExchange(String, String) - Method in class com.devebot.opflow.OpflowExecutor
 
defineQueue(String) - Method in class com.devebot.opflow.OpflowExecutor
 
defineQueue(String, Boolean, Boolean, Boolean) - 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
 
detectFreePort(Integer[]) - Static method in class com.devebot.opflow.supports.OpflowNetTool
 
DONE - Static variable in interface com.devebot.opflow.OpflowRpcListener
 

E

emitCompleted(byte[]) - Method in class com.devebot.opflow.OpflowRpcResponse
 
emitCompleted(String) - Method in class com.devebot.opflow.OpflowRpcResponse
 
emitFailed(byte[]) - Method in class com.devebot.opflow.OpflowRpcResponse
 
emitFailed(String) - 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(byte[]) - Method in class com.devebot.opflow.OpflowRpcResponse
 
emitStarted(String) - 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
 
enabled() - Method in annotation type com.devebot.opflow.annotation.OpflowTargetRoutine
 
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.supports.OpflowJsonTool
 
extractFieldAsInt(String, String) - Static method in class com.devebot.opflow.supports.OpflowJsonTool
 
extractResult() - Method in class com.devebot.opflow.OpflowRpcRequest
 
extractResult(boolean) - Method in class com.devebot.opflow.OpflowRpcRequest
 

F

finalize() - Method in class com.devebot.opflow.OpflowCommander
 
finalize() - Method in class com.devebot.opflow.OpflowEngine
 
finalize() - Method in class com.devebot.opflow.OpflowRpcMaster
 
finalize() - Method in class com.devebot.opflow.OpflowRpcWorker
 
finalize() - Method in class com.devebot.opflow.OpflowServerlet
 
format(String, Map<String, Object>) - Static method in class com.devebot.opflow.supports.OpflowTextFormat
 
fromISO8601UTC(String) - Static method in class com.devebot.opflow.OpflowUtil
 

G

get(String) - Method in class com.devebot.opflow.OpflowLogTracer
 
get(String) - Method in class com.devebot.opflow.OpflowUtil.MapBuilder
 
getAccumulator() - Method in class com.devebot.opflow.OpflowRpcChecker.Pong
 
getAllAncestorTypes(Class<?>) - Static method in class com.devebot.opflow.OpflowUtil
 
getAMQPEntrypointCode(Map<String, Object>) - Static method in class com.devebot.opflow.OpflowUtil
 
getApplicationId() - Method in class com.devebot.opflow.OpflowEngine
 
getApplicationId() - Method in class com.devebot.opflow.OpflowRpcResponse
 
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
 
getCallbackAutoDelete() - Method in class com.devebot.opflow.OpflowRpcMaster
 
getCallbackDurable() - Method in class com.devebot.opflow.OpflowRpcMaster
 
getCallbackExclusive() - Method in class com.devebot.opflow.OpflowRpcMaster
 
getCallbackName() - Method in class com.devebot.opflow.OpflowRpcMaster
 
getCallbackName() - Method in class com.devebot.opflow.OpflowRpcWorker
 
getChannel() - Method in class com.devebot.opflow.OpflowEngine.ConsumerInfo
 
getChecker() - Method in class com.devebot.opflow.OpflowRpcWorker.Middleware
 
getClassSimpleName(Class) - Static method in class com.devebot.opflow.OpflowUtil
 
getConfigurationExtension(URL) - Static method in class com.devebot.opflow.OpflowConfig
 
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.OpflowTimeout.Countdown
 
getCurrentTime() - Static method in class com.devebot.opflow.OpflowUtil
 
getCurrentTimeString() - Static method in class com.devebot.opflow.OpflowUtil
 
getDefaultHandlers() - Method in class com.devebot.opflow.OpflowCommander
 
getDefaultHandlers() - Method in class com.devebot.opflow.OpflowRestServer
 
getDescriptorBuilder() - Static method in class com.devebot.opflow.OpflowServerlet
 
getDispatchName() - Method in class com.devebot.opflow.OpflowRpcWorker
 
getEngine() - Method in class com.devebot.opflow.OpflowRpcMaster
 
getEngine() - Method in class com.devebot.opflow.OpflowRpcWorker
 
getEnvironVariable(String, String) - Static method in class com.devebot.opflow.OpflowUtil
 
getEnvironVariable(String, String) - Method in class com.devebot.opflow.supports.OpflowEnvtool
 
getError() - Method in class com.devebot.opflow.OpflowRpcResult
 
getErrorAsString() - Method in class com.devebot.opflow.OpflowRpcResult
 
getExchangeDurable() - Method in class com.devebot.opflow.OpflowEngine
 
getExchangeName() - Method in class com.devebot.opflow.OpflowEngine
 
getExecutor() - Method in class com.devebot.opflow.OpflowPubsubHandler
 
getExecutor() - Method in class com.devebot.opflow.OpflowRpcMaster
 
getExecutor() - Method in class com.devebot.opflow.OpflowRpcWorker
 
getExpiration() - Method in class com.devebot.opflow.OpflowRpcMaster
 
getInfo() - Method in class com.devebot.opflow.OpflowMessage
 
getInfo() - Method in class com.devebot.opflow.OpflowRpcResult.Step
 
getInstance() - Static method in class com.devebot.opflow.OpflowPromMeasurer
 
getInstanceId() - Method in class com.devebot.opflow.OpflowRpcMaster
 
getIntanceId() - Method in class com.devebot.opflow.OpflowRpcWorker
 
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
 
getMethodSignature(Method) - Static method in class com.devebot.opflow.OpflowUtil
 
getOptionField(Map<String, Object>, String[]) - Static method in class com.devebot.opflow.OpflowUtil
 
getOptionField(Map<String, Object>, String[], Object) - Static method in class com.devebot.opflow.OpflowUtil
 
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
 
getOtherKeys() - Method in class com.devebot.opflow.OpflowEngine
 
getParameters() - Method in class com.devebot.opflow.OpflowRpcChecker.Pong
 
getPercent() - Method in class com.devebot.opflow.OpflowRpcResult.Step
 
getProgress() - Method in class com.devebot.opflow.OpflowRpcResult
 
getQ() - Method in class com.devebot.opflow.OpflowRpcChecker.Ping
 
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
 
getReplyQueueName() - Method in class com.devebot.opflow.OpflowRpcResponse
 
getRequestId() - Method in class com.devebot.opflow.OpflowRpcRequest
 
getRequestId() - Method in class com.devebot.opflow.OpflowRpcResponse
 
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
 
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
 
getRoutingKey() - Method in class com.devebot.opflow.OpflowEngine
 
getRpcListeners() - Method in class com.devebot.opflow.OpflowServerlet.ListenerDescriptor
 
getSendMethodName() - Static method in class com.devebot.opflow.OpflowRpcChecker
 
getStatus() - Method in class com.devebot.opflow.OpflowRpcChecker.Info
 
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
 
getSystemProperty(String, String) - Method in class com.devebot.opflow.supports.OpflowEnvtool
 
getTimeout() - Method in class com.devebot.opflow.OpflowRpcRequest
 
getTimeout() - Method in interface com.devebot.opflow.OpflowTimeout.Timeoutable
 
getTimestamp() - Method in class com.devebot.opflow.OpflowRpcRequest
 
getTimestamp() - Method in interface com.devebot.opflow.OpflowTimeout.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.OpflowRpcResponse
 
getWorkerTag() - Method in class com.devebot.opflow.OpflowRpcResult
 

H

handleEvent() - Method in interface com.devebot.opflow.OpflowTimeout.Listener
 
handleEvent(Channel) - Method in interface com.devebot.opflow.OpflowEngine.Operator
 
has(Logger, String) - Static method in class com.devebot.opflow.OpflowLogTracer
 
hasNext() - Method in class com.devebot.opflow.OpflowRpcRequest
 
hidePasswordInUri(String) - Static method in class com.devebot.opflow.OpflowUtil
 

I

INC - com.devebot.opflow.OpflowPromMeasurer.GaugeAction
 
incEngineConnectionGauge(ConnectionFactory, String) - Method in class com.devebot.opflow.OpflowPromExporter
 
incEngineConnectionGauge(ConnectionFactory, String) - Method in class com.devebot.opflow.OpflowPromMeasurer
 
incRpcInvocationEvent(String, String, String, String) - Method in class com.devebot.opflow.OpflowPromExporter
 
incRpcInvocationEvent(String, String, String, String) - Method in class com.devebot.opflow.OpflowPromMeasurer
 
info() - Method in class com.devebot.opflow.OpflowRestServer
 
Info(Map<String, Object>, OpflowRpcChecker.Pong) - Constructor for class com.devebot.opflow.OpflowRpcChecker.Info
 
Info(Map<String, Object>, Throwable) - Constructor for class com.devebot.opflow.OpflowRpcChecker.Info
 
instance - Static variable in class com.devebot.opflow.supports.OpflowEnvtool
 
instantiateType(Class) - Method in class com.devebot.opflow.OpflowServerlet
 
instantiateType(Class) - Method in class com.devebot.opflow.OpflowServerlet.Instantiator
 
instantiateType(Class, Object) - Method in class com.devebot.opflow.OpflowServerlet
 
instantiateType(Class, Object) - Method in class com.devebot.opflow.OpflowServerlet.Instantiator
 
instantiateTypes(Class[]) - Method in class com.devebot.opflow.OpflowServerlet
 
instantiateTypes(Collection<Class>) - Method in class com.devebot.opflow.OpflowServerlet
 
Instantiator(OpflowRpcWorker, OpflowPubsubHandler) - Constructor for class com.devebot.opflow.OpflowServerlet.Instantiator
 
Instantiator(OpflowRpcWorker, OpflowPubsubHandler, Map<String, Object>) - Constructor for class com.devebot.opflow.OpflowServerlet.Instantiator
 
intercept(Map<String, Object>, Set<String>) - Method in interface com.devebot.opflow.OpflowLogTracer.StringifyInterceptor
 
isAMQPEntrypointNull(Map<String, Object>) - Static method in class com.devebot.opflow.OpflowUtil
 
isAsync() - Method in annotation type com.devebot.opflow.annotation.OpflowSourceRoutine
 
isCompleted() - Method in class com.devebot.opflow.OpflowRpcResult
 
isComponentEnabled(Map<String, Object>) - Static method in class com.devebot.opflow.OpflowUtil
 
isCongested() - Method in class com.devebot.opflow.OpflowRpcWatcher
 
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
 
isGenericDeclaration(String) - Static method in class com.devebot.opflow.OpflowUtil
 
isLocked() - Method in class com.devebot.opflow.OpflowRpcMaster
 
isMute() - Method in class com.devebot.opflow.OpflowLogTracer.OmitPingLogs
 
isReserveWorkerEnabled() - Method in class com.devebot.opflow.OpflowCommander
 
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.OpflowConfig
 
loadConfiguration() - Method in interface com.devebot.opflow.OpflowConfig.Loader
 
loadConfiguration() - Method in class com.devebot.opflow.OpflowConfig.LoaderImplCommander
 
loadConfiguration() - Method in class com.devebot.opflow.OpflowConfig.LoaderImplPubsubHandler
 
loadConfiguration() - Method in class com.devebot.opflow.OpflowConfig.LoaderImplRpcMaster
 
loadConfiguration() - Method in class com.devebot.opflow.OpflowConfig.LoaderImplRpcWorker
 
loadConfiguration() - Method in class com.devebot.opflow.OpflowConfig.LoaderImplServerlet
 
loadConfiguration(String) - Static method in class com.devebot.opflow.OpflowConfig
 
loadConfiguration(Map<String, Object>, String) - Static method in class com.devebot.opflow.OpflowConfig
 
loadConfiguration(Map<String, Object>, String, boolean) - Static method in class com.devebot.opflow.OpflowConfig
 
LoaderImplCommander(Map<String, Object>, String, boolean) - Constructor for class com.devebot.opflow.OpflowConfig.LoaderImplCommander
 
LoaderImplPubsubHandler(Map<String, Object>, String, boolean) - Constructor for class com.devebot.opflow.OpflowConfig.LoaderImplPubsubHandler
 
LoaderImplRpcMaster(Map<String, Object>, String, boolean) - Constructor for class com.devebot.opflow.OpflowConfig.LoaderImplRpcMaster
 
LoaderImplRpcWorker(Map<String, Object>, String, boolean) - Constructor for class com.devebot.opflow.OpflowConfig.LoaderImplRpcWorker
 
LoaderImplServerlet(Map<String, Object>, String, boolean) - Constructor for class com.devebot.opflow.OpflowConfig.LoaderImplServerlet
 
loadProperties() - Static method in class com.devebot.opflow.OpflowConfig
 

M

MapBuilder() - Constructor for class com.devebot.opflow.OpflowUtil.MapBuilder
 
MapBuilder(Map<String, Object>) - Constructor for class com.devebot.opflow.OpflowUtil.MapBuilder
 
maskPassword(String) - Static method in class com.devebot.opflow.OpflowUtil
 
match(String) - Method in interface com.devebot.opflow.OpflowRpcWorker.Checker
 
mergeConfiguration(Map<String, Object>, Map<String, Object>) - Static method in class com.devebot.opflow.OpflowConfig
 
mergeConfiguration(Map<String, Object>, Properties) - Static method in class com.devebot.opflow.OpflowConfig
 
mergeLists(List<T>, List<T>) - Static method in class com.devebot.opflow.OpflowUtil
 
Middleware(OpflowRpcWorker.Checker, OpflowRpcListener) - Constructor for class com.devebot.opflow.OpflowRpcWorker.Middleware
 
Monitor(Map<String, ? extends OpflowTimeout.Timeoutable>) - Constructor for class com.devebot.opflow.OpflowTimeout.Monitor
 
Monitor(Map<String, ? extends OpflowTimeout.Timeoutable>, int) - Constructor for class com.devebot.opflow.OpflowTimeout.Monitor
 
Monitor(Map<String, ? extends OpflowTimeout.Timeoutable>, int, long) - Constructor for class com.devebot.opflow.OpflowTimeout.Monitor
 
Monitor(Map<String, ? extends OpflowTimeout.Timeoutable>, int, long, String) - Constructor for class com.devebot.opflow.OpflowTimeout.Monitor
 

N

next() - Method in class com.devebot.opflow.OpflowRpcRequest
 
NEXT - Static variable in interface com.devebot.opflow.OpflowRpcListener
 
NULL - Static variable in class com.devebot.opflow.OpflowPromMeasurer
 

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(String, Throwable, boolean, boolean) - Constructor for exception com.devebot.opflow.exception.OpflowBootstrapException
 
OpflowBootstrapException(Throwable) - 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(OpflowConfig.Loader) - Constructor for class com.devebot.opflow.OpflowCommander
 
OpflowCommander(Map<String, Object>) - Constructor for class com.devebot.opflow.OpflowCommander
 
OpflowConfig - Class in com.devebot.opflow
 
OpflowConfig() - Constructor for class com.devebot.opflow.OpflowConfig
 
OpflowConfig.Loader - Interface in com.devebot.opflow
 
OpflowConfig.LoaderImplCommander - Class in com.devebot.opflow
 
OpflowConfig.LoaderImplPubsubHandler - Class in com.devebot.opflow
 
OpflowConfig.LoaderImplRpcMaster - Class in com.devebot.opflow
 
OpflowConfig.LoaderImplRpcWorker - Class in com.devebot.opflow
 
OpflowConfig.LoaderImplServerlet - Class in com.devebot.opflow
 
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(String, Throwable, boolean, boolean) - Constructor for exception com.devebot.opflow.exception.OpflowConnectionException
 
OpflowConnectionException(Throwable) - 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(String, Throwable, boolean, boolean) - Constructor for exception com.devebot.opflow.exception.OpflowConsumerOverLimitException
 
OpflowConsumerOverLimitException(Throwable) - Constructor for exception com.devebot.opflow.exception.OpflowConsumerOverLimitException
 
OpflowConverter - Class in com.devebot.opflow.supports
 
OpflowDateTime - Class in com.devebot.opflow.supports
 
OpflowDateTime() - Constructor for class com.devebot.opflow.supports.OpflowDateTime
 
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
 
OpflowEnvtool - Class in com.devebot.opflow.supports
 
OpflowEnvtool() - Constructor for class com.devebot.opflow.supports.OpflowEnvtool
 
OpflowExecutor - Class in com.devebot.opflow
 
OpflowExecutor(OpflowEngine) - Constructor for class com.devebot.opflow.OpflowExecutor
 
OpflowFailedConversionException - Exception in com.devebot.opflow.exception
 
OpflowFailedConversionException() - Constructor for exception com.devebot.opflow.exception.OpflowFailedConversionException
 
OpflowFailedConversionException(String) - Constructor for exception com.devebot.opflow.exception.OpflowFailedConversionException
 
OpflowFailedConversionException(String, Throwable) - Constructor for exception com.devebot.opflow.exception.OpflowFailedConversionException
 
OpflowFailedConversionException(String, Throwable, boolean, boolean) - Constructor for exception com.devebot.opflow.exception.OpflowFailedConversionException
 
OpflowFailedConversionException(Throwable) - Constructor for exception com.devebot.opflow.exception.OpflowFailedConversionException
 
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(String, Throwable, boolean, boolean) - Constructor for exception com.devebot.opflow.exception.OpflowInterceptionException
 
OpflowInterceptionException(Throwable) - Constructor for exception com.devebot.opflow.exception.OpflowInterceptionException
 
OpflowJsontool - Class in com.devebot.opflow
Deprecated.
OpflowJsontool() - Constructor for class com.devebot.opflow.OpflowJsontool
Deprecated.
 
OpflowJsonTool - Class in com.devebot.opflow.supports
 
OpflowJsonTool() - Constructor for class com.devebot.opflow.supports.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(String, Throwable, boolean, boolean) - Constructor for exception com.devebot.opflow.exception.OpflowJsonTransformationException
 
OpflowJsonTransformationException(Throwable) - Constructor for exception com.devebot.opflow.exception.OpflowJsonTransformationException
 
OpflowKeytool - Class in com.devebot.opflow.supports
 
OpflowKeytool() - Constructor for class com.devebot.opflow.supports.OpflowKeytool
 
OpflowListener - Interface in com.devebot.opflow
 
OpflowLogTracer - Class in com.devebot.opflow
 
OpflowLogTracer() - Constructor for class com.devebot.opflow.OpflowLogTracer
 
OpflowLogTracer.OmitPingLogs - Class in com.devebot.opflow
 
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
 
OpflowNetTool - Class in com.devebot.opflow.supports
 
OpflowNetTool() - Constructor for class com.devebot.opflow.supports.OpflowNetTool
 
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(String, Throwable, boolean, boolean) - Constructor for exception com.devebot.opflow.exception.OpflowOperationException
 
OpflowOperationException(Throwable) - Constructor for exception com.devebot.opflow.exception.OpflowOperationException
 
OpflowPromExporter - Class in com.devebot.opflow
 
OpflowPromExporter() - Constructor for class com.devebot.opflow.OpflowPromExporter
 
OpflowPromMeasurer - Class in com.devebot.opflow
 
OpflowPromMeasurer() - Constructor for class com.devebot.opflow.OpflowPromMeasurer
 
OpflowPromMeasurer.GaugeAction - Enum in com.devebot.opflow
 
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(String, Throwable, boolean, boolean) - Constructor for exception com.devebot.opflow.exception.OpflowRequestFailureException
 
OpflowRequestFailureException(Throwable) - Constructor for exception com.devebot.opflow.exception.OpflowRequestFailureException
 
OpflowRequestSuspendException - Exception in com.devebot.opflow.exception
 
OpflowRequestSuspendException() - Constructor for exception com.devebot.opflow.exception.OpflowRequestSuspendException
 
OpflowRequestSuspendException(String) - Constructor for exception com.devebot.opflow.exception.OpflowRequestSuspendException
 
OpflowRequestSuspendException(String, Throwable) - Constructor for exception com.devebot.opflow.exception.OpflowRequestSuspendException
 
OpflowRequestSuspendException(String, Throwable, boolean, boolean) - Constructor for exception com.devebot.opflow.exception.OpflowRequestSuspendException
 
OpflowRequestSuspendException(Throwable) - Constructor for exception com.devebot.opflow.exception.OpflowRequestSuspendException
 
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(String, Throwable, boolean, boolean) - Constructor for exception com.devebot.opflow.exception.OpflowRequestTimeoutException
 
OpflowRequestTimeoutException(Throwable) - Constructor for exception com.devebot.opflow.exception.OpflowRequestTimeoutException
 
OpflowRequestWaitingException - Exception in com.devebot.opflow.exception
 
OpflowRequestWaitingException() - Constructor for exception com.devebot.opflow.exception.OpflowRequestWaitingException
 
OpflowRequestWaitingException(String) - Constructor for exception com.devebot.opflow.exception.OpflowRequestWaitingException
 
OpflowRequestWaitingException(String, Throwable) - Constructor for exception com.devebot.opflow.exception.OpflowRequestWaitingException
 
OpflowRequestWaitingException(String, Throwable, boolean, boolean) - Constructor for exception com.devebot.opflow.exception.OpflowRequestWaitingException
 
OpflowRequestWaitingException(Throwable) - Constructor for exception com.devebot.opflow.exception.OpflowRequestWaitingException
 
OpflowRestServer - Class in com.devebot.opflow
 
OpflowRpcChecker - Class in com.devebot.opflow
 
OpflowRpcChecker() - Constructor for class com.devebot.opflow.OpflowRpcChecker
 
OpflowRpcChecker.Info - Class in com.devebot.opflow
 
OpflowRpcChecker.Ping - Class in com.devebot.opflow
 
OpflowRpcChecker.Pong - Class in com.devebot.opflow
 
OpflowRpcCheckerWorker() - Constructor for class com.devebot.opflow.OpflowServerlet.OpflowRpcCheckerWorker
 
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>, OpflowTimeout.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
 
OpflowRpcWatcher - Class in com.devebot.opflow
 
OpflowRpcWatcher(OpflowRpcChecker) - Constructor for class com.devebot.opflow.OpflowRpcWatcher
 
OpflowRpcWatcher(OpflowRpcChecker, Map<String, Object>) - Constructor for class com.devebot.opflow.OpflowRpcWatcher
 
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, OpflowConfig.Loader) - Constructor for class com.devebot.opflow.OpflowServerlet
 
OpflowServerlet(OpflowServerlet.ListenerDescriptor, OpflowConfig.Loader, Map<String, Object>) - Constructor for class com.devebot.opflow.OpflowServerlet
 
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
 
OpflowServerlet.OpflowRpcCheckerWorker - Class in com.devebot.opflow
 
OpflowSourceRoutine - Annotation Type in com.devebot.opflow.annotation
 
OpflowTargetRoutine - Annotation Type in com.devebot.opflow.annotation
 
OpflowTaskSubmitter - Interface in com.devebot.opflow
 
OpflowTextFormat - Class in com.devebot.opflow.supports
 
OpflowTextFormat() - Constructor for class com.devebot.opflow.supports.OpflowTextFormat
 
OpflowTimeout - Class in com.devebot.opflow
 
OpflowTimeout() - Constructor for class com.devebot.opflow.OpflowTimeout
 
OpflowTimeout.Countdown - Class in com.devebot.opflow
 
OpflowTimeout.Listener - Interface in com.devebot.opflow
 
OpflowTimeout.Monitor - Class in com.devebot.opflow
 
OpflowTimeout.Timeoutable - Interface in com.devebot.opflow
 
OpflowTimeout.Watcher - Class in com.devebot.opflow
 
OpflowUnimplementedException - Exception in com.devebot.opflow.exception
 
OpflowUnimplementedException() - Constructor for exception com.devebot.opflow.exception.OpflowUnimplementedException
 
OpflowUnimplementedException(String) - Constructor for exception com.devebot.opflow.exception.OpflowUnimplementedException
 
OpflowUnimplementedException(String, Throwable) - Constructor for exception com.devebot.opflow.exception.OpflowUnimplementedException
 
OpflowUnimplementedException(String, Throwable, boolean, boolean) - Constructor for exception com.devebot.opflow.exception.OpflowUnimplementedException
 
OpflowUnimplementedException(Throwable) - Constructor for exception com.devebot.opflow.exception.OpflowUnimplementedException
 
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

PARAM_RESERVE_WORKER_ENABLED - Static variable in class com.devebot.opflow.OpflowCommander
 
PARAMETER_NAMES - Static variable in class com.devebot.opflow.OpflowEngine
 
pause(long) - Method in class com.devebot.opflow.OpflowRpcMaster
 
pause(long) - Method in interface com.devebot.opflow.OpflowTaskSubmitter
 
ping() - Method in class com.devebot.opflow.OpflowRestServer
 
ping(String) - Method in class com.devebot.opflow.OpflowCommander
 
Ping() - Constructor for class com.devebot.opflow.OpflowRpcChecker.Ping
 
Ping(String) - Constructor for class com.devebot.opflow.OpflowRpcChecker.Ping
 
Pong() - Constructor for class com.devebot.opflow.OpflowRpcChecker.Pong
 
Pong(Map<String, Object>) - Constructor for class com.devebot.opflow.OpflowRpcChecker.Pong
 
printElapsedTime(Date, Date) - Static method in class com.devebot.opflow.supports.OpflowDateTime
 
process() - Method in class com.devebot.opflow.OpflowServerlet.Instantiator
 
process(OpflowRpcListener) - Method in class com.devebot.opflow.OpflowRpcWorker
 
process(OpflowRpcWorker.Checker, 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
 
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>, AMQP.BasicProperties.Builder, Map<String, Object>) - Method in class com.devebot.opflow.OpflowEngine
 
produce(byte[], Map<String, Object>, Map<String, Object>) - Method in class com.devebot.opflow.OpflowEngine
 
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
 
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
 
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.OpflowTimeout.Timeoutable
 
ready(Logger, String) - Method in class com.devebot.opflow.OpflowLogTracer
 
registerType(Class<T>) - Method in class com.devebot.opflow.OpflowCommander
 
registerType(Class<T>, T) - Method in class com.devebot.opflow.OpflowCommander
 
removeComponentInstance(String, String) - Method in class com.devebot.opflow.OpflowPromExporter
 
removeComponentInstance(String, String) - Method in class com.devebot.opflow.OpflowPromMeasurer
 
removeInterceptor(OpflowLogTracer.StringifyInterceptor) - Static method in class com.devebot.opflow.OpflowLogTracer
 
request(String, byte[]) - Method in class com.devebot.opflow.OpflowRpcMaster
 
request(String, byte[], Map<String, Object>) - Method in class com.devebot.opflow.OpflowRpcMaster
 
request(String, String) - Method in class com.devebot.opflow.OpflowRpcMaster
 
request(String, String, Map<String, Object>) - Method in class com.devebot.opflow.OpflowRpcMaster
 
REQUEST_ATTRS - Static variable in class com.devebot.opflow.OpflowRpcChecker
 
reset() - Method in class com.devebot.opflow.OpflowLogTracer
 
reset() - Method in interface com.devebot.opflow.OpflowTaskSubmitter
 
reset() - Method in class com.devebot.opflow.supports.OpflowEnvtool
 
reset(int) - Method in class com.devebot.opflow.OpflowTimeout.Countdown
 
reset(int, long) - Method in class com.devebot.opflow.OpflowTimeout.Countdown
 
ROOT - Static variable in class com.devebot.opflow.OpflowLogTracer
 
RPC_DETECTION_INTERVAL - Static variable in class com.devebot.opflow.OpflowRpcWatcher
 
run() - Method in class com.devebot.opflow.OpflowTimeout.Watcher
 

S

send(OpflowRpcChecker.Ping) - Method in class com.devebot.opflow.OpflowRpcChecker
 
send(OpflowRpcChecker.Ping) - Method in class com.devebot.opflow.OpflowServerlet.OpflowRpcCheckerWorker
 
serve() - Method in class com.devebot.opflow.OpflowCommander
 
serve() - Method in class com.devebot.opflow.OpflowRestServer
 
serve(RoutingHandler) - Method in class com.devebot.opflow.OpflowCommander
 
serve(RoutingHandler) - Method in class com.devebot.opflow.OpflowRestServer
 
serve(RoutingHandler, Map<String, Object>) - Method in class com.devebot.opflow.OpflowRestServer
 
SERVICE_BEAN_NAMES - Static variable in class com.devebot.opflow.OpflowCommander
 
setAccumulator(Map<String, Object>) - Method in class com.devebot.opflow.OpflowRpcChecker.Pong
 
setConfigurer(OpflowPubsubListener) - Method in class com.devebot.opflow.OpflowServerlet.DescriptorBuilder
 
setCongested(boolean) - Method in class com.devebot.opflow.OpflowRpcWatcher
 
setEnvironVariable(String, String) - Method in class com.devebot.opflow.supports.OpflowEnvtool
 
setParameters(Map<String, Object>) - Method in class com.devebot.opflow.OpflowRpcChecker.Pong
 
setQ(String) - Method in class com.devebot.opflow.OpflowRpcChecker.Ping
 
setReserveWorkerEnabled(boolean) - Method in class com.devebot.opflow.OpflowCommander
 
setSubscriber(OpflowPubsubListener) - Method in class com.devebot.opflow.OpflowServerlet.DescriptorBuilder
 
setSystemProperty(String, String) - Method in class com.devebot.opflow.supports.OpflowEnvtool
 
splitByComma(String) - Static method in class com.devebot.opflow.OpflowUtil
 
splitByComma(String, Class<T>) - Static method in class com.devebot.opflow.OpflowUtil
 
start() - Method in class com.devebot.opflow.OpflowRpcWatcher
 
start() - Method in class com.devebot.opflow.OpflowServerlet
 
start() - Method in class com.devebot.opflow.OpflowTimeout.Monitor
 
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.OpflowTimeout.Monitor
 
stringify() - Method in class com.devebot.opflow.OpflowLogTracer
 
stringify(boolean) - Method in class com.devebot.opflow.OpflowLogTracer
 
stringify(String) - Method in class com.devebot.opflow.OpflowLogTracer
 
stringify(String, boolean) - Method in class com.devebot.opflow.OpflowLogTracer
 
subscribe(OpflowPubsubListener) - Method in class com.devebot.opflow.OpflowPubsubHandler
 
SUPPORT_BEAN_NAMES - Static variable in class com.devebot.opflow.OpflowCommander
 

T

tags(String) - Method in class com.devebot.opflow.OpflowLogTracer
 
tags(String[]) - Method in class com.devebot.opflow.OpflowLogTracer
 
text(String) - Method in class com.devebot.opflow.OpflowLogTracer
 
toISO8601UTC(Date) - Static method in class com.devebot.opflow.OpflowUtil
 
toMap() - Method in class com.devebot.opflow.OpflowUtil.MapBuilder
 
toObject(OpflowMessage, Class<T>) - Static method in class com.devebot.opflow.supports.OpflowJsonTool
 
toObject(InputStream, Class<T>) - Static method in class com.devebot.opflow.supports.OpflowJsonTool
 
toObject(Reader, Class<T>) - Static method in class com.devebot.opflow.supports.OpflowJsonTool
 
toObject(String, Class<T>) - Static method in class com.devebot.opflow.supports.OpflowJsonTool
 
toObjectArray(String, Class[]) - Static method in class com.devebot.opflow.supports.OpflowJsonTool
 
toObjectMap(String) - Static method in class com.devebot.opflow.supports.OpflowJsonTool
 
toString() - Method in class com.devebot.opflow.OpflowLogTracer
 
toString() - Method in class com.devebot.opflow.OpflowRpcChecker.Info
 
toString() - Method in class com.devebot.opflow.OpflowUtil.MapBuilder
 
toString(boolean) - Method in class com.devebot.opflow.OpflowRpcChecker.Info
 
toString(boolean) - Method in class com.devebot.opflow.OpflowUtil.MapBuilder
 
toString(Object) - Static method in class com.devebot.opflow.supports.OpflowJsonTool
 
toString(Object[], Type[]) - Static method in class com.devebot.opflow.supports.OpflowJsonTool
 
toString(Object[], Type[], boolean) - Static method in class com.devebot.opflow.supports.OpflowJsonTool
 
toString(Object, boolean) - Static method in class com.devebot.opflow.supports.OpflowJsonTool
 
toString(Map<String, Object>) - Static method in class com.devebot.opflow.supports.OpflowJsonTool
 
toString(Map<String, Object>, boolean) - Static method in class com.devebot.opflow.supports.OpflowJsonTool
 
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

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

V

valueOf(String) - Static method in enum com.devebot.opflow.OpflowPromMeasurer.GaugeAction
Returns the enum constant of this type with the specified name.
values() - Static method in enum com.devebot.opflow.OpflowPromMeasurer.GaugeAction
Returns an array containing the constants of this enum type, in the order they are declared.

W

Watcher(String, long, long, OpflowTimeout.Listener) - Constructor for class com.devebot.opflow.OpflowTimeout.Watcher
 
Watcher(String, long, OpflowTimeout.Listener) - Constructor for class com.devebot.opflow.OpflowTimeout.Watcher
 
A B C D E F G H I J L M N O P R S T U V W 
All Classes All Packages