All Classes

Class	Description
AwaitRetry
BatchCall	Groups responses for batch call and let user to get them when all of them are ready.
BrokerCommandCallback	This interface provides a way to pass a logic which is run after the specific command was invoked.
Call	Call holds single response and uses BatchCall as internal implementation to promote code reuse.
ClientConnectionException	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 as Map.
EventPublisher	Jsonrpc implementation of Publisher
EventSubscriber	Subscription id contains <receiver>.<component>.<operation_id>.<unique_id>.
JsonResponseUtil
JsonRpcCall	Abstraction for single and batch calls to be updated when response arrives.
JsonRpcClient	ReactorClient wrapper 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 internal Lock.
ManagerProvider	Provides abstraction for obtaining TrustManagers and KeyManagers.
Message
Message.Command
MessageContext	Context containing a message and client.
OneTimeCallback
PlainClient	ReactorClient implementation to provide not encrypted communication.
Publisher<T,S extends Subscriber<T>>
Reactor	Provides Reactor abstraction which reacts on incoming messages and let ReactorClient process them.
ReactorClient	Abstract implementation of JsonRpcClient which handles low level networking.
ReactorClient.MessageListener
ReactorFactory	Factory class which provide single instance of Reactors or ResponseWorker within single loading scope.
ReactorListener	NioListener provides a way to react on incoming messages.
ReactorListener.EventListener
ReactorScheduler	Utility class used for processing FutureTasks.
ReactorType
Reciever
RequestAlreadySentException	Exception used to inform user that there is an attempt to sent the same request second time.
RequestBuilder	Utility class which helps to build JsonRpcRequest by providing information like method name and parameters.
ResponseBuilder	Utility class which helps to build JsonRpcResponse by 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	ResponseWorker is responsible to process responses for all the JsonRpcClient and it is produced by ReactorFactory.
Retryable<T>	Wrapper of any Callable which retries call method execution based on provided RetryPolicy.
RetryContext	RetryConext represents current execution retry state.
Sender
ServerListener
SSLClient	ReactorClient implementation to provide encrypted communication.
SSLEngineNioHelper	Helper object responsible for low level ssl communication.
SSLStompClient
SSLStompListener
SSLStompReactor
StompClient
StompClientPolicy
StompCommonClient
StompListener
StompReactor
Subscriber<T>	Will receive call to Subscriber.onSubscribe(Subscription) once after passing an instance of Subscriber to Publisher.subscribe(Subscriber).
Subscription	A Subscription represents a one-to-one lifecycle of a Subscriber subscribing to a Publisher.
SubscriptionHolder	Holds subscription information such as amount of messages requested by EventSubscriber.
SubscriptionMatcher	Matcher is responsible for holding all subscriptions and match them to incoming events.