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
All Classes All Packages
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
All Classes All Packages