All Classes and Interfaces
Class
Description
This interface provides a way to pass a logic which is run
after the specific command was invoked.
Call holds single responseGeneric json-rpc client exception which wraps IO or encryption relates exceptions.
Java bean which provide information how retry logic should work.
Default implementation of operation level retry functionality.
Default implementation of connection level retry functionality.
Decomposes events as
Map.Jsonrpc implementation of
Flow.PublisherSubscription id contains <receiver>.<component>.<operation_id>.<unique_id>.
Abstraction for single and batch calls to be updated
when response arrives.
ReactorClient wrapper which provides ability to send single or batched requests.Java bean representing error information from json message.
Java bean representation of an event.
Java bean representation of the request.
Java bean representing response object.
Utility class for json marshalling.
Lock wrapper object which allows to use try-finally block to auto unlock
internal
Lock.Provides abstraction for obtaining
TrustManagers and KeyManagers.Context containing a message and client.
ReactorClient implementation to provide not encrypted communication.Provides
Reactor abstraction which reacts on
incoming messages and let ReactorClient process
them.Abstract implementation of
JsonRpcClient which handles low level networking.Factory class which provide single instance of
Reactors or ResponseWorker within single
loading scope.NioListener provides a way to react on incoming messages.Utility class used for processing
FutureTasks.Exception used to inform user that there is an attempt to sent
the same request second time.
Utility class which helps to build
JsonRpcRequest by providing
information like method name and parameters.Utility class which helps to build
JsonRpcResponse by providing
information like response or error.Decomposes of the response as objects which type is provided.
Response tracker thread is responsible for tracking and retrying requests.
ResponseWorker is responsible to process responses for all the JsonRpcClient and it is produced
by ReactorFactory.Wrapper of any
Callable which retries call method execution based on provided RetryPolicy.RetryConext represents current execution retry
state.ReactorClient implementation to provide encrypted communication.Helper object responsible for low level ssl communication.
Holds subscription information such as amount of messages requested by
EventSubscriber.Matcher is responsible for holding all subscriptions and match them to incoming events.