All Classes
-
All Classes Interface Summary Class Summary Enum Summary Exception Summary Class Description AwaitRetry BrokerCommandCallback This interface provides a way to pass a logic which is run after the specific command was invoked.Call Callholds single responseClientConnectionException Generic json-rpc client exception which wraps IO or encryption relates exceptions.ClientPolicy Java bean which provide information how retry logic should work.CommandExecutor CommandFactory DefaultClientRetryPolicy Default implementation of operation level retry functionality.DefaultConnectionRetryPolicy Default implementation of connection level retry functionality.EventDecomposer Decomposes events asMap.EventPublisher Jsonrpc implementation ofFlow.PublisherEventSubscriber Subscription id contains <receiver>.<component>.<operation_id>.<unique_id>.JsonResponseUtil JsonRpcCall Abstraction for single and batch calls to be updated when response arrives.JsonRpcClient ReactorClientwrapper which provides ability to send single or batched requests.JsonRpcError Java bean representing error information from json message.JsonRpcEvent Java bean representation of an event.JsonRpcRequest Java bean representation of the request.JsonRpcResponse Java bean representing response object.JsonUtils Utility class for json marshalling.Listener LockWrapper Lock wrapper object which allows to use try-finally block to auto unlock internalLock.ManagerProvider Provides abstraction for obtainingTrustManagers andKeyManagers.Message Message.Command MessageContext Context containing a message and client.OneTimeCallback PlainClient ReactorClientimplementation to provide not encrypted communication.Reactor ProvidesReactorabstraction which reacts on incoming messages and letReactorClientprocess them.ReactorClient Abstract implementation ofJsonRpcClientwhich handles low level networking.ReactorClient.MessageListener ReactorFactory Factory class which provide single instance ofReactors orResponseWorkerwithin single loading scope.ReactorListener NioListenerprovides a way to react on incoming messages.ReactorListener.EventListener ReactorScheduler Utility class used for processingFutureTasks.ReactorType Receiver RequestAlreadySentException Exception used to inform user that there is an attempt to sent the same request second time.RequestBuilder Utility class which helps to buildJsonRpcRequestby providing information like method name and parameters.ResponseBuilder Utility class which helps to buildJsonRpcResponseby providing information like response or error.ResponseDecomposer Decomposes of the response as objects which type is provided.ResponseTracker Response tracker thread is responsible for tracking and retrying requests.ResponseTracking ResponseWorker ResponseWorkeris responsible to process responses for all theJsonRpcClientand it is produced byReactorFactory.ResponseWorker.ResponseForkJoinWorkerThread Retryable<T> Wrapper of anyCallablewhich retries call method execution based on providedRetryPolicy.RetryContext RetryConextrepresents current execution retry state.Sender ServerListener SSLClient ReactorClientimplementation to provide encrypted communication.SSLEngineNioHelper Helper object responsible for low level ssl communication.SSLStompClient SSLStompListener SSLStompReactor StompClient StompClientPolicy StompCommonClient StompListener StompReactor SubscriptionHolder Holds subscription information such as amount of messages requested byEventSubscriber.SubscriptionMatcher Matcher is responsible for holding all subscriptions and match them to incoming events.SubscriptionMatcher.Predicate