All Classes
-
All Classes Interface Summary Class Summary Enum Summary Exception Summary 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 usesBatchCall
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 asMap
.EventPublisher Jsonrpc implementation ofPublisher
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 internalLock
.ManagerProvider Provides abstraction for obtainingTrustManager
s andKeyManager
s.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 ProvidesReactor
abstraction which reacts on incoming messages and letReactorClient
process them.ReactorClient Abstract implementation ofJsonRpcClient
which handles low level networking.ReactorClient.MessageListener ReactorFactory Factory class which provide single instance ofReactor
s orResponseWorker
within single loading scope.ReactorListener NioListener
provides a way to react on incoming messages.ReactorListener.EventListener ReactorScheduler Utility class used for processingFutureTask
s.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 buildJsonRpcRequest
by providing information like method name and parameters.ResponseBuilder Utility class which helps to buildJsonRpcResponse
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 theJsonRpcClient
and it is produced byReactorFactory
.Retryable<T> Wrapper of anyCallable
which retries call method execution based on providedRetryPolicy
.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 toSubscriber.onSubscribe(Subscription)
once after passing an instance ofSubscriber
toPublisher.subscribe(Subscriber)
.Subscription 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