- Reactor - Class in org.ovirt.vdsm.jsonrpc.client.reactors
-
Provides Reactor
abstraction which reacts on
incoming messages and let ReactorClient
process
them.
- Reactor() - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.Reactor
-
- reactor - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
-
- ReactorClient - Class in org.ovirt.vdsm.jsonrpc.client.reactors
-
Abstract implementation of JsonRpcClient
which handles low level networking.
- ReactorClient(Reactor, String, int) - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
-
- ReactorClient.MessageListener - Interface in org.ovirt.vdsm.jsonrpc.client.reactors
-
- ReactorFactory - Class in org.ovirt.vdsm.jsonrpc.client.reactors
-
Factory class which provide single instance of Reactor
s or ResponseWorker
within single
loading scope.
- ReactorFactory() - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorFactory
-
- ReactorListener - Class in org.ovirt.vdsm.jsonrpc.client.reactors
-
NioListener
provides a way to react on incoming messages.
- ReactorListener(Reactor, InetSocketAddress, Selector, ReactorListener.EventListener) - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorListener
-
- ReactorListener.EventListener - Interface in org.ovirt.vdsm.jsonrpc.client.reactors
-
- ReactorScheduler - Class in org.ovirt.vdsm.jsonrpc.client.utils
-
Utility class used for processing FutureTask
s.
- ReactorScheduler() - Constructor for class org.ovirt.vdsm.jsonrpc.client.utils.ReactorScheduler
-
- ReactorType - Enum in org.ovirt.vdsm.jsonrpc.client.reactors
-
- read(ByteBuffer) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.PlainClient
-
- read(ByteBuffer) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
-
Reads provided buffer.
- read(ByteBuffer) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLClient
-
- read(ByteBuffer) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLEngineNioHelper
-
- receipt() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
-
- recieve(Message, SelectionKey) - Method in interface org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Reciever
-
- Reciever - Interface in org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl
-
- reduceGracePeriod(int) - Static method in class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
-
- register(ReactorClient) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseWorker
-
Registers new client with ResponseWorker
.
- registerCall(JsonRpcRequest, JsonRpcCall) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseTracker
-
- registerTrackingRequest(JsonRpcRequest, ResponseTracking) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseTracker
-
- remove(SubscriptionHolder) - Method in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionMatcher
-
Used during removal of a subscription.
- removeCall(JsonNode) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseTracker
-
- removeCall(Future<JsonRpcResponse>) - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcClient
-
- removeEventListener(ReactorClient.MessageListener) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
-
- request(int) - Method in interface org.reactivestreams.Subscription
-
No events will be sent by a
Publisher
until demand is signaled via this method.
- RequestAlreadySentException - Exception in org.ovirt.vdsm.jsonrpc.client
-
Exception used to inform user that there is an attempt to sent
the same request second time.
- RequestAlreadySentException() - Constructor for exception org.ovirt.vdsm.jsonrpc.client.RequestAlreadySentException
-
- RequestAlreadySentException(String) - Constructor for exception org.ovirt.vdsm.jsonrpc.client.RequestAlreadySentException
-
- RequestAlreadySentException(Throwable) - Constructor for exception org.ovirt.vdsm.jsonrpc.client.RequestAlreadySentException
-
- RequestAlreadySentException(String, Throwable) - Constructor for exception org.ovirt.vdsm.jsonrpc.client.RequestAlreadySentException
-
- RequestAlreadySentException(String, Throwable, boolean, boolean) - Constructor for exception org.ovirt.vdsm.jsonrpc.client.RequestAlreadySentException
-
- RequestBuilder - Class in org.ovirt.vdsm.jsonrpc.client
-
Utility class which helps to build
JsonRpcRequest
by providing
information like method name and parameters.
- RequestBuilder(String) - Constructor for class org.ovirt.vdsm.jsonrpc.client.RequestBuilder
-
Creates builder with required methodName.
- resetExecution() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.OneTimeCallback
-
- ResponseBuilder - Class in org.ovirt.vdsm.jsonrpc.client
-
Utility class which helps to build
JsonRpcResponse
by providing
information like response or error.
- ResponseBuilder(JsonNode) - Constructor for class org.ovirt.vdsm.jsonrpc.client.ResponseBuilder
-
Creates builder with required response id.
- ResponseDecomposer - Class in org.ovirt.vdsm.jsonrpc.client
-
Decomposes of the response as objects which type is provided.
- ResponseDecomposer(JsonRpcResponse) - Constructor for class org.ovirt.vdsm.jsonrpc.client.ResponseDecomposer
-
Creates decomposer for a response.
- ResponseTracker - Class in org.ovirt.vdsm.jsonrpc.client.internal
-
Response tracker thread is responsible for tracking and retrying requests.
- ResponseTracker() - Constructor for class org.ovirt.vdsm.jsonrpc.client.internal.ResponseTracker
-
- ResponseTracking - Class in org.ovirt.vdsm.jsonrpc.client.utils
-
- ResponseTracking(JsonRpcRequest, JsonRpcCall, RetryContext, long, ReactorClient, boolean) - Constructor for class org.ovirt.vdsm.jsonrpc.client.utils.ResponseTracking
-
- ResponseWorker - Class in org.ovirt.vdsm.jsonrpc.client.internal
-
- ResponseWorker(int) - Constructor for class org.ovirt.vdsm.jsonrpc.client.internal.ResponseWorker
-
- Retryable<T> - Class in org.ovirt.vdsm.jsonrpc.client.utils.retry
-
Wrapper of any
Callable
which retries call method execution based on provided
RetryPolicy
.
- Retryable(Callable<T>, ClientPolicy) - Constructor for class org.ovirt.vdsm.jsonrpc.client.utils.retry.Retryable
-
- RetryContext - Class in org.ovirt.vdsm.jsonrpc.client.utils.retry
-
RetryConext
represents current execution retry
state.
- RetryContext(ClientPolicy) - Constructor for class org.ovirt.vdsm.jsonrpc.client.utils.retry.RetryContext
-
- run() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseTracker
-
- run() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseWorker
-
- run() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.Reactor
-
Main loop for message processing.