A B C D E F G H I J K L M N O P Q R S T U V W
All Classes All Packages
All Classes All Packages
All Classes All Packages
A
- abort() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- ABORT - org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message.Command
- accept() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorListener
- ack() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- ACK - org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message.Command
- add(SubscriptionHolder) - Method in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionMatcher
-
Adds a
SubscriptionHolder
which will be used for event matching - addEventListener(ReactorClient.MessageListener) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- addGracePeriod(int) - Static method in class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
- addHolders(Set<SubscriptionHolder>, ConcurrentMap<String, List<SubscriptionHolder>>, int, String[], SubscriptionMatcher.Predicate) - Method in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionMatcher
- addResponse(JsonRpcResponse) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.BatchCall
- addResponse(JsonRpcResponse) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.Call
- addResponse(JsonRpcResponse) - Method in interface org.ovirt.vdsm.jsonrpc.client.internal.JsonRpcCall
- ALL - Static variable in class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
- allSubscriptions - Variable in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionMatcher
- appBuffer - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLEngineNioHelper
- apply(int, int) - Method in interface org.ovirt.vdsm.jsonrpc.client.events.SubscriptionMatcher.Predicate
- appPeerBuffer - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLEngineNioHelper
- arrivalTime - Variable in class org.ovirt.vdsm.jsonrpc.client.JsonRpcEvent
- await(long, TimeUnit) - Method in class org.ovirt.vdsm.jsonrpc.client.utils.OneTimeCallback
- AwaitRetry - Class in org.ovirt.vdsm.jsonrpc.client.utils.retry
- AwaitRetry() - Constructor for class org.ovirt.vdsm.jsonrpc.client.utils.retry.AwaitRetry
B
- batchCall - Variable in class org.ovirt.vdsm.jsonrpc.client.internal.Call
- batchCall(List<JsonRpcRequest>) - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcClient
-
Sends requests in batch and returns
Future
representation ofJsonRpcResponse
. - BatchCall - Class in org.ovirt.vdsm.jsonrpc.client.internal
-
Groups responses for batch call and let user to get them when all of them are ready.
- BatchCall(List<JsonRpcRequest>) - Constructor for class org.ovirt.vdsm.jsonrpc.client.internal.BatchCall
- BatchCall(List<JsonRpcRequest>, BrokerCommandCallback) - Constructor for class org.ovirt.vdsm.jsonrpc.client.internal.BatchCall
- begin() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- BEGIN - org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message.Command
- beginHandshake() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLEngineNioHelper
- BrokerCommandCallback - Interface in org.ovirt.vdsm.jsonrpc.client
-
This interface provides a way to pass a logic which is run after the specific command was invoked.
- BUFFER_SIZE - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- build() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- build() - Method in class org.ovirt.vdsm.jsonrpc.client.RequestBuilder
-
Builds
JsonRpcRequest
based on provided method name, parameter and generates id usingUUID
. - build() - Method in class org.ovirt.vdsm.jsonrpc.client.ResponseBuilder
-
Builds
JsonRpcResponse
based on provided id, result and error. - buildErrorResponse(JsonNode, T, String) - Static method in class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
- buildFailedResponse(JsonRpcRequest) - Static method in class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
- buildNetworkResponse(String) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
-
Builds network issue message for specific protocol.
- buildNetworkResponse(String) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
C
- call - Variable in class org.ovirt.vdsm.jsonrpc.client.utils.ResponseTracking
- call() - Method in class org.ovirt.vdsm.jsonrpc.client.events.EventPublisher.EventCallable
- call() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.retry.Retryable
- call(JsonRpcRequest) - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcClient
-
Sends single request and returns
Future
representation ofJsonRpcResponse
. - call(JsonRpcRequest, BrokerCommandCallback) - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcClient
- Call - Class in org.ovirt.vdsm.jsonrpc.client.internal
-
Call
holds single response and usesBatchCall
as internal implementation to promote code reuse. - Call(JsonRpcRequest) - Constructor for class org.ovirt.vdsm.jsonrpc.client.internal.Call
- Call(JsonRpcRequest, BrokerCommandCallback) - Constructor for class org.ovirt.vdsm.jsonrpc.client.internal.Call
- callable - Variable in class org.ovirt.vdsm.jsonrpc.client.utils.retry.Retryable
- callback - Variable in class org.ovirt.vdsm.jsonrpc.client.internal.BatchCall
- callback - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLEngineNioHelper
- callback - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.SSLStompClient
- callback - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompClient
- cancel(boolean) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.BatchCall
- cancel(boolean) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.Call
- canProcess() - Method in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionHolder
- canProcessMore() - Method in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionHolder
- channel - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- channel - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorListener
- channel - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLEngineNioHelper
- CHARSET - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- checkActions(Set<SelectionKey>) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.Reactor
- checkAndExecute() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.OneTimeCallback
- checkAndUpdateStatus() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.JsonResponseUtil
- clazz - Variable in class org.ovirt.vdsm.jsonrpc.client.utils.JsonResponseUtil
- clean() - Method in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionHolder
-
Clean event queue.
- clean() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
-
Cleans internal state.
- clean() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
- clean(ConcurrentMap<String, List<SubscriptionHolder>>, String, SubscriptionHolder) - Method in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionMatcher
- clean(SubscriptionHolder) - Method in class org.ovirt.vdsm.jsonrpc.client.events.EventPublisher
- cleanupOldEvents() - Method in class org.ovirt.vdsm.jsonrpc.client.events.EventPublisher
- clearBuff() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLEngineNioHelper
- client - Variable in class org.ovirt.vdsm.jsonrpc.client.internal.MessageContext
- client - Variable in class org.ovirt.vdsm.jsonrpc.client.JsonRpcClient
- client - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLClient
- client - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLEngineNioHelper
- client - Variable in class org.ovirt.vdsm.jsonrpc.client.utils.ResponseTracking
- CLIENT_CLOSED - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- ClientConnectionException - Exception in org.ovirt.vdsm.jsonrpc.client
-
Generic json-rpc client exception which wraps IO or encryption relates exceptions.
- ClientConnectionException() - Constructor for exception org.ovirt.vdsm.jsonrpc.client.ClientConnectionException
- ClientConnectionException(String) - Constructor for exception org.ovirt.vdsm.jsonrpc.client.ClientConnectionException
- ClientConnectionException(String, Throwable) - Constructor for exception org.ovirt.vdsm.jsonrpc.client.ClientConnectionException
- ClientConnectionException(String, Throwable, boolean, boolean) - Constructor for exception org.ovirt.vdsm.jsonrpc.client.ClientConnectionException
- ClientConnectionException(Throwable) - Constructor for exception org.ovirt.vdsm.jsonrpc.client.ClientConnectionException
- ClientPolicy - Class in org.ovirt.vdsm.jsonrpc.client.internal
-
Java bean which provide information how retry logic should work.
- ClientPolicy(int, int, int) - Constructor for class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
- ClientPolicy(int, int, int, int) - Constructor for class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
- ClientPolicy(int, int, int, int, Class<? extends Exception>) - Constructor for class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
- ClientPolicy(int, int, int, int, List<Class<? extends Exception>>) - Constructor for class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
-
Create policy using provided values.
- ClientPolicy(int, int, int, Class<? extends Exception>) - Constructor for class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
- clone() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
- clone() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompClientPolicy
- cloneBuffer(ByteBuffer) - Static method in class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
- close() - Method in class org.ovirt.vdsm.jsonrpc.client.events.EventPublisher
- close() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseTracker
- close() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseWorker
- close() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcClient
- close() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.Reactor
- close() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- close() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorListener
- close() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
- close() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.LockWrapper
- closeChannel() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- closing - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- code - Variable in class org.ovirt.vdsm.jsonrpc.client.internal.JsonRpcError
- command - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- Command() - Constructor for enum org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message.Command
- CommandExecutor - Interface in org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl
- commandFactory - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.SSLStompListener
- commandFactory - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompListener
- CommandFactory - Class in org.ovirt.vdsm.jsonrpc.client.reactors.stomp
- CommandFactory(Sender, List<ReactorClient.MessageListener>) - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.CommandFactory
- commands - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.CommandFactory
- commit() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- COMMIT - org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message.Command
- component - Variable in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionMatcher
- connect() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- connect() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- CONNECT - org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message.Command
- connected - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
- connected() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- CONNECTED - org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message.Command
- content - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- context - Variable in class org.ovirt.vdsm.jsonrpc.client.utils.ResponseTracking
- context - Variable in class org.ovirt.vdsm.jsonrpc.client.utils.retry.Retryable
- count - Variable in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionHolder
- countEvents(JsonRpcEvent) - Method in class org.ovirt.vdsm.jsonrpc.client.events.EventPublisher
- createClient(String, int) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.Reactor
- createClient(Reactor, Selector, String, int) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.Reactor
- createClient(Reactor, Selector, String, int) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.SSLStompReactor
- createClient(Reactor, Selector, String, int) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompReactor
- createConnectedClient(Reactor, Selector, String, int, SocketChannel) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.Reactor
- createConnectedClient(Reactor, Selector, String, int, SocketChannel) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.SSLStompReactor
- createConnectedClient(Reactor, Selector, String, int, SocketChannel) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompReactor
- createListener(String, int, ReactorListener.EventListener) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.Reactor
- createSSLEngine(boolean) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLClient
D
- data - Variable in class org.ovirt.vdsm.jsonrpc.client.internal.JsonRpcError
- decompose(JsonRpcEvent) - Method in class org.ovirt.vdsm.jsonrpc.client.EventDecomposer
-
Decomposes an event to a map.
- decomposeError() - Method in class org.ovirt.vdsm.jsonrpc.client.ResponseDecomposer
-
Decomposes response error as
Map
. - decomposer - Variable in class org.ovirt.vdsm.jsonrpc.client.events.EventPublisher
- decomposer - Variable in class org.ovirt.vdsm.jsonrpc.client.events.EventPublisher.EventCallable
- decomposeResponse(Class<T>) - Method in class org.ovirt.vdsm.jsonrpc.client.ResponseDecomposer
-
Decomposes response to provided type.
- decomposeTypedArray(Object[], Class<T>, String) - Method in class org.ovirt.vdsm.jsonrpc.client.ResponseDecomposer
-
Decomposes response to provided typed array.
- decreaseAttempts() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.retry.RetryContext
- DECREMENT_ONLY_POSITIVE - Static variable in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionHolder
- DEFAULT_KEY - Static variable in class org.ovirt.vdsm.jsonrpc.client.utils.JsonResponseUtil
- DEFAULT_REQUEST_QUEUE - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
- DEFAULT_RESPONSE_QUEUE - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
- DefaultClientRetryPolicy - Class in org.ovirt.vdsm.jsonrpc.client.utils.retry
-
Default implementation of operation level retry functionality.
- DefaultClientRetryPolicy() - Constructor for class org.ovirt.vdsm.jsonrpc.client.utils.retry.DefaultClientRetryPolicy
- DefaultConnectionRetryPolicy - Class in org.ovirt.vdsm.jsonrpc.client.utils.retry
-
Default implementation of connection level retry functionality.
- DefaultConnectionRetryPolicy() - Constructor for class org.ovirt.vdsm.jsonrpc.client.utils.retry.DefaultConnectionRetryPolicy
- destinations - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.CommandFactory
- disconnect() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- disconnect(String) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- DISCONNECT - org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message.Command
E
- emitOnMessageReceived(byte[]) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- emitOnMessageReceived(Message) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
- END_OF_MESSAGE - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- engine - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLEngineNioHelper
- error - Variable in class org.ovirt.vdsm.jsonrpc.client.JsonRpcResponse
- error - Variable in class org.ovirt.vdsm.jsonrpc.client.ResponseBuilder
- error() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- error(Map<String, String>) - Method in interface org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Listener
- ERROR - org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message.Command
- ERROR_KEY - Static variable in class org.ovirt.vdsm.jsonrpc.client.JsonRpcEvent
- EVENT_TIMEOUT_IN_HOURS - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorFactory
-
Default timeout to clean up unprocessed events, which are in the queue more than this timeout.
- EventCallable(SubscriptionHolder, EventDecomposer) - Constructor for class org.ovirt.vdsm.jsonrpc.client.events.EventPublisher.EventCallable
- EventDecomposer - Class in org.ovirt.vdsm.jsonrpc.client
-
Decomposes events as
Map
. - EventDecomposer() - Constructor for class org.ovirt.vdsm.jsonrpc.client.EventDecomposer
- eventListener - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorListener
- eventListeners - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- eventListeners - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.CommandFactory
- EventPublisher - Class in org.ovirt.vdsm.jsonrpc.client.events
-
Jsonrpc implementation of
Flow.Publisher
- EventPublisher(ExecutorService, int) - Constructor for class org.ovirt.vdsm.jsonrpc.client.events.EventPublisher
- EventPublisher.EventCallable - Class in org.ovirt.vdsm.jsonrpc.client.events
-
Event processing task which is submit to a
ExecutorService
for processing. - eventQueue - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompClientPolicy
- events - Variable in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionHolder
- EventSubscriber - Class in org.ovirt.vdsm.jsonrpc.client.events
-
Subscription id contains <receiver>.<component>.<operation_id>.<unique_id>.
- EventSubscriber(String) - Constructor for class org.ovirt.vdsm.jsonrpc.client.events.EventSubscriber
- eventTimeoutInHours - Variable in class org.ovirt.vdsm.jsonrpc.client.events.EventPublisher
- exceptions - Variable in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
- execute() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.OneTimeCallback
- execute(Message) - Method in interface org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.CommandExecutor
- executed - Variable in class org.ovirt.vdsm.jsonrpc.client.utils.OneTimeCallback
- executorService - Variable in class org.ovirt.vdsm.jsonrpc.client.events.EventPublisher
- executorService - Variable in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseTracker
- executorService - Variable in class org.ovirt.vdsm.jsonrpc.client.JsonRpcClient
- extractResponse(List<JsonRpcResponse>) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.Call
F
- factory - Static variable in class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
- filter() - Method in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionHolder
- filteredId - Variable in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionHolder
- fromByteArray(byte[]) - Static method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcEvent
- fromByteArray(byte[]) - Static method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcRequest
- fromByteArray(byte[]) - Static method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcResponse
-
Validates and builds
JsonRpcResponse
based on provided json node. - fromJson(JsonNode) - Static method in class org.ovirt.vdsm.jsonrpc.client.internal.JsonRpcError
-
Creates
JsonRpcError
representation from providedJsonNode
message. - fromJsonNode(JsonNode) - Static method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcEvent
-
Validates and builds
JsonRpcEvent
based on provided json node. - fromJsonNode(JsonNode) - Static method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcRequest
-
Validates and builds
JsonRpcRequest
based on provided json node. - fromJsonNode(JsonNode) - Static method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcResponse
-
Validates and builds
JsonRpcResponse
based on provided json node. - fromMethodAndParams(String, Map<String, Object>) - Static method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcEvent
-
Create notification object for the method and params.
G
- get() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.BatchCall
- get() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.Call
- get(long, TimeUnit) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.BatchCall
- get(long, TimeUnit) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.Call
- getAddress(String, int) - Static method in class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
- getAllSubscriptions() - Method in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionMatcher
- getArrivalTime() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcEvent
- getCall() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.ResponseTracking
- getCallback() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.BatchCall
- getCallback() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.Call
- getCallback() - Method in interface org.ovirt.vdsm.jsonrpc.client.internal.JsonRpcCall
-
The callback to notify after the specific command was invoked.
- getClient() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.MessageContext
- getClient() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcClient
- getClient() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.ResponseTracking
- getClientId() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- getClientRetryPolicy() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcClient
- getCode() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.JsonRpcError
- getCommand() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- getCommandExecutor(String) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.CommandFactory
- getConnectionId() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcClient
- getConnectionId() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- getContent() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- getContent(byte[], String[], int) - Static method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- getContentLength() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- getContext() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.ResponseTracking
- getData() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.JsonRpcError
- getEncoding() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- getError() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcResponse
- getEventQueue() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompClientPolicy
- getEventQueue() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
- getExceptions() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
- getFilteredId() - Method in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionHolder
- getHeaders() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- getHeartbeatTime() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- getHostMap() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseTracker
- getHostname() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcClient
- getHostname() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- getId() - Method in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionHolder
- getId() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.BatchCall
- getId() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.Call
- getId() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcRequest
- getId() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcResponse
- getIdentifier() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
- getIncomingHeartbeat() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
- getKeyManagers() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ManagerProvider
- getMessage() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.JsonRpcError
- getMessage() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.MessageContext
- getMessage(ByteBuffer, int) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
- getMethod() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcEvent
- getMethod() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcRequest
- getNumberOfAttempts() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.retry.RetryContext
- getNumberOfEvents() - Method in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionHolder
- getOutgoingHeartbeat() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
- getParams() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcEvent
- getParams() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcRequest
- getParsedId() - Method in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionHolder
- getPeerCertificates() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- getPeerCertificates() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLClient
- getPlainId() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcRequest
- getPort() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorListener
- getPostConnectCallback() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- getPostConnectCallback() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.SSLStompClient
- getPostConnectCallback() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompClient
- getPublisher() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseWorker
- getReactor(ManagerProvider, ReactorType) - Static method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorFactory
-
Provides instance of
Reactor
based onManagerProvider
availability and type provided. - getReactorName() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.Reactor
- getReactorName() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.SSLStompReactor
- getReactorName() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompReactor
- getRequest() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.ResponseTracking
- getRequestQueue() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompClientPolicy
- getRequestQueue() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
- getResponseQueue() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompClientPolicy
- getResponseQueue() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
- getResult() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcResponse
- getRetryNumber() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
- getRetryPolicy() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcClient
- getRetryPolicy() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- getRetryTimeOut() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
- getSelectionKey() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- getSSLContext() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ManagerProvider
- getSSLEngine() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLEngineNioHelper
- getSslStompReactor(ManagerProvider) - Static method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorFactory
- getStompReactor(ManagerProvider) - Static method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorFactory
- getSubscriber() - Method in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionHolder
- getSubscriptionId() - Method in class org.ovirt.vdsm.jsonrpc.client.events.EventSubscriber
- getTimeout() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.ResponseTracking
- getTimeout() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.retry.RetryContext
- getTimeout(int, TimeUnit) - Static method in class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
- getTimeUnit() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
- getTimeUnit() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.retry.RetryContext
- getTrustManagers() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ManagerProvider
- getWorker(int) - Static method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorFactory
- getWorker(int, int) - Static method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorFactory
- GRACE_PERIOD - Static variable in class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
H
- half - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- handleEvent(Flow.Subscriber<Map<String, Object>>, JsonRpcEvent) - Method in class org.ovirt.vdsm.jsonrpc.client.events.EventPublisher.EventCallable
- handleException(Throwable, ReactorClient, SelectionKey, String) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.Reactor
- handleFailure(ResponseTracking, JsonNode) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseTracker
- handshakeInProgress() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLEngineNioHelper
- HEADER_ACCEPT - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- HEADER_ACK - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- HEADER_CONTENT_LENGTH - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- HEADER_CONTENT_TYPE - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- HEADER_CORRELATION_ID - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- HEADER_DESTINATION - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- HEADER_HEART_BEAT - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- HEADER_HOST - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- HEADER_ID - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- HEADER_MESSAGE - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- HEADER_RECEIPT - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- HEADER_RECEIPT_ID - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- HEADER_REPLY_TO - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- HEADER_TRANSACTION - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- headerBuffer - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
- headers - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- HEARTBEAT_FRAME - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- holder - Variable in class org.ovirt.vdsm.jsonrpc.client.events.EventPublisher.EventCallable
- hostname - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- hostToId - Variable in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseTracker
I
- ibuff - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- id - Variable in class org.ovirt.vdsm.jsonrpc.client.JsonRpcRequest
- id - Variable in class org.ovirt.vdsm.jsonrpc.client.JsonRpcResponse
- id - Variable in class org.ovirt.vdsm.jsonrpc.client.ResponseBuilder
- identifier - Variable in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
- ids - Variable in class org.ovirt.vdsm.jsonrpc.client.internal.BatchCall
- ignoreResponseKey - Variable in class org.ovirt.vdsm.jsonrpc.client.utils.JsonResponseUtil
- incomingHeartbeat - Variable in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
- isCancelled() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.BatchCall
- isCancelled() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.Call
- isClosed() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcClient
- isDone() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.BatchCall
- isDone() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.Call
- isEmpty(String) - Static method in class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
- isError() - Method in class org.ovirt.vdsm.jsonrpc.client.ResponseDecomposer
- isExceptionRetryable(Exception) - Method in class org.ovirt.vdsm.jsonrpc.client.utils.retry.RetryContext
- isIncomingHeartbeat - Variable in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
- isIncomingHeartbeat() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
- isIncomingHeartbeatExceeded() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- isInInit() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- isInInit() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.SSLStompClient
- isInInit() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompClient
- isOpen() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- isOutgoingHeartbeat - Variable in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
- isOutgoingHeartbeat() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
- isOutgoingHeartbeatExceeded() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- isResetConnection() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.ResponseTracking
- isRunning - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.Reactor
- isTracking - Variable in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseTracker
J
- JsonResponseUtil - Class in org.ovirt.vdsm.jsonrpc.client.utils
- JsonResponseUtil() - Constructor for class org.ovirt.vdsm.jsonrpc.client.utils.JsonResponseUtil
- JsonRpcCall - Interface in org.ovirt.vdsm.jsonrpc.client.internal
-
Abstraction for single and batch calls to be updated when response arrives.
- JsonRpcClient - Class in org.ovirt.vdsm.jsonrpc.client
-
ReactorClient
wrapper which provides ability to send single or batched requests. - JsonRpcClient(ReactorClient, ResponseTracker) - Constructor for class org.ovirt.vdsm.jsonrpc.client.JsonRpcClient
-
Wraps
ReactorClient
to hide response update details. - JsonRpcError - Class in org.ovirt.vdsm.jsonrpc.client.internal
-
Java bean representing error information from json message.
- JsonRpcError(int, String, JsonNode) - Constructor for class org.ovirt.vdsm.jsonrpc.client.internal.JsonRpcError
- JsonRpcEvent - Class in org.ovirt.vdsm.jsonrpc.client
-
Java bean representation of an event.
- JsonRpcEvent(String, JsonNode) - Constructor for class org.ovirt.vdsm.jsonrpc.client.JsonRpcEvent
-
Creates notification object.
- JsonRpcRequest - Class in org.ovirt.vdsm.jsonrpc.client
-
Java bean representation of the request.
- JsonRpcRequest(String, JsonNode, JsonNode) - Constructor for class org.ovirt.vdsm.jsonrpc.client.JsonRpcRequest
-
Creates request object.
- JsonRpcResponse - Class in org.ovirt.vdsm.jsonrpc.client
-
Java bean representing response object.
- JsonRpcResponse(JsonNode, JsonNode, JsonNode) - Constructor for class org.ovirt.vdsm.jsonrpc.client.JsonRpcResponse
-
Creates response object.
- jsonToByteArray(JsonNode) - Static method in class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
- jsonToByteArray(List<JsonRpcRequest>) - Static method in class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
- JsonUtils - Class in org.ovirt.vdsm.jsonrpc.client.utils
-
Utility class for json marshalling.
- JsonUtils() - Constructor for class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
K
- key - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
L
- lastIncomingHeartbeat - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- lastOutgoingHeartbeat - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- latch - Variable in class org.ovirt.vdsm.jsonrpc.client.internal.BatchCall
- latch - Variable in class org.ovirt.vdsm.jsonrpc.client.utils.OneTimeCallback
- LIMIT - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- Listener - Interface in org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl
- listeners - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.CommandFactory
- lock - Variable in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionHolder
- lock - Variable in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseTracker
- lock - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- lock - Variable in class org.ovirt.vdsm.jsonrpc.client.utils.LockWrapper
- LockWrapper - Class in org.ovirt.vdsm.jsonrpc.client.utils
-
Lock wrapper object which allows to use try-finally block to auto unlock internal
Lock
. - LockWrapper(Lock) - Constructor for class org.ovirt.vdsm.jsonrpc.client.utils.LockWrapper
- log - Static variable in class org.ovirt.vdsm.jsonrpc.client.EventDecomposer
- log - Static variable in class org.ovirt.vdsm.jsonrpc.client.events.EventPublisher
- log - Static variable in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseTracker
- log - Static variable in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseWorker
- log - Variable in class org.ovirt.vdsm.jsonrpc.client.JsonRpcClient
- log - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- log - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorListener
- log - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLClient
- log - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.SSLStompListener
- log - Static variable in class org.ovirt.vdsm.jsonrpc.client.ResponseDecomposer
- log - Static variable in class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
- log - Static variable in class org.ovirt.vdsm.jsonrpc.client.utils.retry.Retryable
- LOG - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.Reactor
- LOG - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- LOG - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
- logException(Logger, String, Throwable) - Static method in class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
- loop() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseTracker
M
- ManagerProvider - Class in org.ovirt.vdsm.jsonrpc.client.reactors
-
Provides abstraction for obtaining
TrustManager
s andKeyManager
s. - ManagerProvider() - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.ManagerProvider
- map - Variable in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseTracker
- mapper - Static variable in class org.ovirt.vdsm.jsonrpc.client.EventDecomposer
- mapper - Static variable in class org.ovirt.vdsm.jsonrpc.client.ResponseDecomposer
- mapper - Static variable in class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
- MAPPER - Static variable in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseWorker
- MAPPER - Static variable in class org.ovirt.vdsm.jsonrpc.client.JsonRpcEvent
- MAPPER - Static variable in class org.ovirt.vdsm.jsonrpc.client.JsonRpcRequest
- MAPPER - Static variable in class org.ovirt.vdsm.jsonrpc.client.JsonRpcResponse
- mapValues(JsonNode) - Static method in class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
- match(JsonRpcEvent) - Method in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionMatcher
-
Matches current subscriptions to an event and returns a
Set
containing all subscriptions that match for this event processing. - matcher - Variable in class org.ovirt.vdsm.jsonrpc.client.events.EventPublisher
- MAX_ATTEMPTS - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLEngineNioHelper
- message - Variable in class org.ovirt.vdsm.jsonrpc.client.internal.JsonRpcError
- message - Variable in class org.ovirt.vdsm.jsonrpc.client.internal.MessageContext
- message - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
- message() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- Message - Class in org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl
- Message() - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- MESSAGE - org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message.Command
- MESSAGE_FORMAT - Static variable in class org.ovirt.vdsm.jsonrpc.client.JsonRpcEvent
- Message.Command - Enum in org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl
- MessageContext - Class in org.ovirt.vdsm.jsonrpc.client.internal
-
Context containing a message and client.
- MessageContext(JsonRpcClient, byte[]) - Constructor for class org.ovirt.vdsm.jsonrpc.client.internal.MessageContext
- method - Variable in class org.ovirt.vdsm.jsonrpc.client.JsonRpcEvent
- method - Variable in class org.ovirt.vdsm.jsonrpc.client.JsonRpcRequest
- methodName - Variable in class org.ovirt.vdsm.jsonrpc.client.RequestBuilder
N
- nioEngine - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLClient
- now() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- numberOfAttempts - Variable in class org.ovirt.vdsm.jsonrpc.client.utils.retry.RetryContext
O
- OBJECT_MAPPER - Static variable in class org.ovirt.vdsm.jsonrpc.client.RequestBuilder
- OBJECT_MAPPER - Static variable in class org.ovirt.vdsm.jsonrpc.client.ResponseBuilder
- onAccept(ReactorClient) - Method in interface org.ovirt.vdsm.jsonrpc.client.reactors.ReactorListener.EventListener
- onComplete() - Method in class org.ovirt.vdsm.jsonrpc.client.events.EventSubscriber
- onError(Throwable) - Method in class org.ovirt.vdsm.jsonrpc.client.events.EventSubscriber
- OneTimeCallback - Class in org.ovirt.vdsm.jsonrpc.client.utils
- OneTimeCallback() - Constructor for class org.ovirt.vdsm.jsonrpc.client.utils.OneTimeCallback
- onFailure(Map<String, Object>) - Method in interface org.ovirt.vdsm.jsonrpc.client.BrokerCommandCallback
-
Whenever any issue occurs during command invocation it will be passed here as an instance of
Throwable
. - onMessageReceived(byte[]) - Method in interface org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient.MessageListener
- onNext(Map<String, Object>) - Method in class org.ovirt.vdsm.jsonrpc.client.events.EventSubscriber
- onResponse(Map<String, Object>) - Method in interface org.ovirt.vdsm.jsonrpc.client.BrokerCommandCallback
-
When a command response arrive this method is invoked and it should contain continuation logic for the command.
- onSubscribe(Flow.Subscription) - Method in class org.ovirt.vdsm.jsonrpc.client.events.EventSubscriber
- operation - Variable in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionMatcher
- org.ovirt.vdsm.jsonrpc.client - package org.ovirt.vdsm.jsonrpc.client
- org.ovirt.vdsm.jsonrpc.client.events - package org.ovirt.vdsm.jsonrpc.client.events
- org.ovirt.vdsm.jsonrpc.client.internal - package org.ovirt.vdsm.jsonrpc.client.internal
- org.ovirt.vdsm.jsonrpc.client.reactors - package org.ovirt.vdsm.jsonrpc.client.reactors
- org.ovirt.vdsm.jsonrpc.client.reactors.stomp - package org.ovirt.vdsm.jsonrpc.client.reactors.stomp
- org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl - package org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl
- org.ovirt.vdsm.jsonrpc.client.utils - package org.ovirt.vdsm.jsonrpc.client.utils
- org.ovirt.vdsm.jsonrpc.client.utils.retry - package org.ovirt.vdsm.jsonrpc.client.utils.retry
- outbox - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- outgoingHeartbeat - Variable in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
P
- packatPeerBuffer - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLEngineNioHelper
- packetBuffer - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLEngineNioHelper
- parameters - Variable in class org.ovirt.vdsm.jsonrpc.client.RequestBuilder
- params - Variable in class org.ovirt.vdsm.jsonrpc.client.JsonRpcEvent
- params - Variable in class org.ovirt.vdsm.jsonrpc.client.JsonRpcRequest
- parse(byte[]) - Static method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- parse(String) - Static method in class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
- parsedId - Variable in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionHolder
- pendingOperations - Variable in class org.ovirt.vdsm.jsonrpc.client.utils.ReactorScheduler
- pendingOperations() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLClient
- performAction() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- performPendingOperations() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.ReactorScheduler
- PlainClient - Class in org.ovirt.vdsm.jsonrpc.client.reactors
-
ReactorClient
implementation to provide not encrypted communication. - PlainClient(Reactor, Selector, String, int) - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.PlainClient
- PlainClient(Reactor, Selector, String, int, SocketChannel) - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.PlainClient
- policy - Variable in class org.ovirt.vdsm.jsonrpc.client.JsonRpcClient
- policy - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- policy - Variable in class org.ovirt.vdsm.jsonrpc.client.utils.retry.RetryContext
- populate(JsonRpcResponse) - Method in class org.ovirt.vdsm.jsonrpc.client.utils.JsonResponseUtil
- port - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- postConnect(OneTimeCallback) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.PlainClient
- postConnect(OneTimeCallback) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
-
Transport specific post connection functionality.
- postConnect(OneTimeCallback) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLClient
- postConnect(OneTimeCallback) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.SSLStompClient
- postConnect(OneTimeCallback) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.SSLStompListener
- postConnect(OneTimeCallback) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompClient
- postConnect(OneTimeCallback) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompListener
- postDisconnect() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.PlainClient
- postDisconnect() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
-
Cleans resources after disconnect.
- postDisconnect() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLClient
- process() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- process() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLClient
- process() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLEngineNioHelper
- process(SubscriptionHolder) - Method in class org.ovirt.vdsm.jsonrpc.client.events.EventPublisher
- process(JsonRpcEvent) - Method in class org.ovirt.vdsm.jsonrpc.client.events.EventPublisher
-
This method is used by @link
ResponseWorker
to submit an @linkJsonRpcEvent
for processing. - processChannels() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.Reactor
-
Processing channels.
- processHeartbeat() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- processIncoming() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
-
Process incoming channel.
- processIncoming() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
- processIncomingObject(JsonRpcClient, JsonNode) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseWorker
- processIssue(JsonRpcResponse) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseTracker
- processMessage(Message) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.SSLStompListener
- processMessage(Message) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
- processMessage(Message) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompListener
- processNotifications(JsonRpcEvent) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseWorker
- processOutgoing() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- processResponse(JsonRpcResponse) - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcClient
- PROTON - org.ovirt.vdsm.jsonrpc.client.reactors.ReactorType
- publish(String, Map<String, Object>) - Method in class org.ovirt.vdsm.jsonrpc.client.events.EventPublisher
- publisher - Variable in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseWorker
- purgeOldEventsIfNotConsumed(int) - Method in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionHolder
-
Purge old events if they have not been consumed in a specified amount of time.
- putBuffer(ByteBuffer) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLEngineNioHelper
- putEvent(JsonRpcEvent) - Method in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionHolder
-
Queues not processed event for later processing.
Q
- queue - Variable in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseTracker
- queue - Variable in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseWorker
- queueFuture(Future<?>) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.Reactor
- queueFuture(Future<?>) - Method in class org.ovirt.vdsm.jsonrpc.client.utils.ReactorScheduler
R
- reactor - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- reactor - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorListener
- Reactor - Class in org.ovirt.vdsm.jsonrpc.client.reactors
-
Provides
Reactor
abstraction which reacts on incoming messages and letReactorClient
process them. - Reactor() - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.Reactor
- 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 orResponseWorker
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
- ReactorType() - Constructor for enum org.ovirt.vdsm.jsonrpc.client.reactors.ReactorType
- 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
- RECEIPT - org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message.Command
- receiver - Variable in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionMatcher
- 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.
- remove(ResponseTracking, JsonNode, JsonRpcResponse) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseTracker
- 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
- removeNodes(List<JsonNode>, JsonRpcResponse) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseTracker
- removeRequestFromTracking(JsonNode) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseTracker
- request - Variable in class org.ovirt.vdsm.jsonrpc.client.utils.ResponseTracking
- 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(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
- RequestAlreadySentException(Throwable) - 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.
- requestQueue - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompClientPolicy
- resetConnection - Variable in class org.ovirt.vdsm.jsonrpc.client.utils.ResponseTracking
- resetExecution() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.OneTimeCallback
- response - Variable in class org.ovirt.vdsm.jsonrpc.client.ResponseDecomposer
- 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.
- ResponseForkJoinWorkerThread(ForkJoinPool) - Constructor for class org.ovirt.vdsm.jsonrpc.client.internal.ResponseWorker.ResponseForkJoinWorkerThread
- responseKey - Variable in class org.ovirt.vdsm.jsonrpc.client.utils.JsonResponseUtil
- responseMap - Variable in class org.ovirt.vdsm.jsonrpc.client.utils.JsonResponseUtil
- responseQueue - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompClientPolicy
- responses - Variable in class org.ovirt.vdsm.jsonrpc.client.internal.BatchCall
- 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
is responsible to process responses for all theJsonRpcClient
and it is produced byReactorFactory
. - ResponseWorker(int, int) - Constructor for class org.ovirt.vdsm.jsonrpc.client.internal.ResponseWorker
- ResponseWorker.ResponseForkJoinWorkerThread - Class in org.ovirt.vdsm.jsonrpc.client.internal
- result - Variable in class org.ovirt.vdsm.jsonrpc.client.JsonRpcResponse
- result - Variable in class org.ovirt.vdsm.jsonrpc.client.ResponseBuilder
- retry(Callable<T>) - Static method in class org.ovirt.vdsm.jsonrpc.client.utils.retry.AwaitRetry
- Retryable<T> - Class in org.ovirt.vdsm.jsonrpc.client.utils.retry
-
Wrapper of any
Callable
which retries call method execution based on providedRetryPolicy
. - Retryable(Callable<T>, ClientPolicy) - Constructor for class org.ovirt.vdsm.jsonrpc.client.utils.retry.Retryable
- retryBatchCall(List<JsonRpcRequest>, BatchCall) - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcClient
- retryCall(JsonRpcRequest, JsonRpcCall) - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcClient
- 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
- retryNumber - Variable in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
- retryTimeOut - Variable in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
- 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.
- runningCalls - Variable in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseTracker
S
- scheduleCleanupTask() - Method in class org.ovirt.vdsm.jsonrpc.client.events.EventPublisher
- scheduleClose(String) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- scheduledExecutorService - Variable in class org.ovirt.vdsm.jsonrpc.client.events.EventPublisher
- scheduler - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.Reactor
- scheduleTask(Callable<T>) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- select() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.Reactor
- selector - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.PlainClient
- selector - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.Reactor
- selector - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorListener
- selector - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLClient
- send() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- send(byte[]) - Method in interface org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Sender
- send(byte[]) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
- SEND - org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message.Command
- sender - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.CommandFactory
- sender - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.ServerListener
- Sender - Interface in org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl
- sendHeartbeat() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
-
Client sends protocol specific heartbeat message
- sendHeartbeat() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
- sendMessage(byte[]) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
-
Sends message using provided byte array.
- sendMessage(byte[]) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.SSLStompClient
- sendMessage(byte[]) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.SSLStompListener
- sendMessage(byte[]) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompClient
- sendMessage(byte[]) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompListener
- sendNow(byte[]) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
- serialVersionUID - Static variable in exception org.ovirt.vdsm.jsonrpc.client.ClientConnectionException
- serialVersionUID - Static variable in exception org.ovirt.vdsm.jsonrpc.client.RequestAlreadySentException
- ServerListener - Class in org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl
- ServerListener(Sender) - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.ServerListener
- setArrivalTime(long) - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcEvent
- setClientPolicy(ClientPolicy) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- setClientPolicy(ClientPolicy) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.SSLStompListener
- setClientPolicy(ClientPolicy) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompListener
- setClientRetryPolicy(ClientPolicy) - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcClient
- setCode(int) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.JsonRpcError
- setCommand(String) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- setData(JsonNode) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.JsonRpcError
- setError(JsonNode) - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcResponse
- setEventQueue(String) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompClientPolicy
- setExecutorService(ScheduledExecutorService) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseTracker
- setExecutorService(ScheduledExecutorService) - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcClient
- setId(JsonNode) - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcRequest
- setId(JsonNode) - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcResponse
- setIdentifier(String) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
- setIncomingHeartbeat(boolean) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
- setIncomingHeartbeat(int) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
- setMessage(String) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.JsonRpcError
- setMethod(String) - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcEvent
- setMethod(String) - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcRequest
- setOutgoingHeartbeat(boolean) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
- setOutgoingHeartbeat(int) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
- setParams(JsonNode) - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcEvent
- setParams(JsonNode) - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcRequest
- setResetConnection(boolean) - Method in class org.ovirt.vdsm.jsonrpc.client.utils.ResponseTracking
- setResult(JsonNode) - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcResponse
- setRetryPolicy(ClientPolicy) - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcClient
- setTimeout(long) - Method in class org.ovirt.vdsm.jsonrpc.client.utils.ResponseTracking
- setTimeUnit(TimeUnit) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
- setupChannel(InetSocketAddress) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorListener
- setWaitForConnect() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.SSLStompClient
- SSLClient - Class in org.ovirt.vdsm.jsonrpc.client.reactors
-
ReactorClient
implementation to provide encrypted communication. - SSLClient(Reactor, Selector, String, int, SSLContext) - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.SSLClient
- SSLClient(Reactor, Selector, String, int, SSLContext, SocketChannel) - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.SSLClient
- sslContext - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLClient
- sslContext - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.SSLStompReactor
- SSLEngineNioHelper - Class in org.ovirt.vdsm.jsonrpc.client.reactors
-
Helper object responsible for low level ssl communication.
- SSLEngineNioHelper(SocketChannel, SSLEngine, OneTimeCallback, SSLClient) - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.SSLEngineNioHelper
- SSLStompClient - Class in org.ovirt.vdsm.jsonrpc.client.reactors.stomp
- SSLStompClient(Reactor, Selector, String, int, SSLContext) - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.SSLStompClient
- SSLStompListener - Class in org.ovirt.vdsm.jsonrpc.client.reactors.stomp
- SSLStompListener(Reactor, Selector, String, int, SocketChannel, SSLContext) - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.SSLStompListener
- sslStompReactor - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorFactory
- SSLStompReactor - Class in org.ovirt.vdsm.jsonrpc.client.reactors.stomp
- SSLStompReactor(SSLContext) - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.SSLStompReactor
- STATUS - Static variable in class org.ovirt.vdsm.jsonrpc.client.utils.JsonResponseUtil
- STATUS_DONE - Static variable in class org.ovirt.vdsm.jsonrpc.client.utils.JsonResponseUtil
- STOMP - org.ovirt.vdsm.jsonrpc.client.reactors.ReactorType
- StompClient - Class in org.ovirt.vdsm.jsonrpc.client.reactors.stomp
- StompClient(Reactor, Selector, String, int) - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompClient
- StompClientPolicy - Class in org.ovirt.vdsm.jsonrpc.client.reactors.stomp
- StompClientPolicy(int, int, int, int, List<Class<? extends Exception>>, String, String) - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompClientPolicy
- StompClientPolicy(int, int, int, Class<? extends Exception>, String, String) - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompClientPolicy
- StompClientPolicy(int, int, int, String, String) - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompClientPolicy
- StompCommonClient - Class in org.ovirt.vdsm.jsonrpc.client.reactors.stomp
- StompCommonClient(Reactor, String, int) - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
- StompListener - Class in org.ovirt.vdsm.jsonrpc.client.reactors.stomp
- StompListener(Reactor, Selector, String, int, SocketChannel) - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompListener
- stompReactor - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorFactory
- StompReactor - Class in org.ovirt.vdsm.jsonrpc.client.reactors.stomp
- StompReactor() - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompReactor
- subscribe() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- subscribe(Flow.Subscriber<? super Map<String, Object>>) - Method in class org.ovirt.vdsm.jsonrpc.client.events.EventPublisher
- SUBSCRIBE - org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message.Command
- subscribed - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
- subscriber - Variable in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionHolder
- SUBSCRIPTION_ALL - Static variable in class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
- SubscriptionHolder - Class in org.ovirt.vdsm.jsonrpc.client.events
-
Holds subscription information such as amount of messages requested by
EventSubscriber
. - SubscriptionHolder(EventSubscriber, AtomicLong) - Constructor for class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionHolder
-
Creates a holder which subscriber instance and count and it prepares subscription id representation for event matching.
- subscriptionId - Variable in class org.ovirt.vdsm.jsonrpc.client.events.EventSubscriber
- subscriptionIds - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
- SubscriptionMatcher - Class in org.ovirt.vdsm.jsonrpc.client.events
-
Matcher is responsible for holding all subscriptions and match them to incoming events.
- SubscriptionMatcher() - Constructor for class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionMatcher
- SubscriptionMatcher.Predicate - Interface in org.ovirt.vdsm.jsonrpc.client.events
- subTypeClazz - Variable in class org.ovirt.vdsm.jsonrpc.client.utils.JsonResponseUtil
- subtypeKey - Variable in class org.ovirt.vdsm.jsonrpc.client.utils.JsonResponseUtil
- swapHeartbeat(String) - Static method in class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
T
- timeout - Variable in class org.ovirt.vdsm.jsonrpc.client.utils.ResponseTracking
- timeout - Variable in class org.ovirt.vdsm.jsonrpc.client.utils.retry.RetryContext
- TIMEOUT - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.Reactor
- TIMEOUT_STATUS - Static variable in class org.ovirt.vdsm.jsonrpc.client.utils.JsonResponseUtil
- timeUnit - Variable in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
- toByteArray() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcResponse
- toJson() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcEvent
- toJson() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcRequest
- toPrintableResult(JsonNode) - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcResponse
- toString() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcEvent
- toString() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcRequest
- toString() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcResponse
- toString() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- tracker - Variable in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseWorker
- tracker - Variable in class org.ovirt.vdsm.jsonrpc.client.JsonRpcClient
- TRACKING_TIMEOUT - Static variable in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseTracker
- trimEndOfMessage() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
U
- unique_id - Variable in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionMatcher
- unsubscribe() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- UNSUBSCRIBE - org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message.Command
- update(String) - Method in interface org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Listener
- update(ConcurrentMap<String, List<SubscriptionHolder>>, String, SubscriptionHolder) - Method in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionMatcher
- update(Message) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.ServerListener
- updateIds(List<JsonRpcRequest>) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.BatchCall
- updateInterestedOps() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.PlainClient
- updateInterestedOps() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
-
Updates selection key's operation set.
- updateInterestedOps() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLClient
- updateLastIncomingHeartbeat() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- updateLastOutgoingHeartbeat() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
- updateOps(byte[]) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
- updatePolicyWithHeartbeat(String, boolean) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
- updateResponse(Object) - Method in class org.ovirt.vdsm.jsonrpc.client.utils.JsonResponseUtil
- UTF8 - Static variable in class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
V
- validate(ClientPolicy) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
-
Validates policy when it is set.
- validate(ClientPolicy) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
- validateKey(String) - Method in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionMatcher
- valueOf(String) - Static method in enum org.ovirt.vdsm.jsonrpc.client.reactors.ReactorType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message.Command
-
Returns the enum constant of this type with the specified name.
- values() - Static method in enum org.ovirt.vdsm.jsonrpc.client.reactors.ReactorType
-
Returns an array containing the constants of this enum type, in the order they are declared.
- values() - Static method in enum org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message.Command
-
Returns an array containing the constants of this enum type, in the order they are declared.
W
- waitForConnect() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.SSLStompClient
- waitOperation() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.retry.RetryContext
- wakeup() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.Reactor
- withAdditionalContent(byte[]) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- withContent(byte[]) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- withCorrelationId() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- withError(Map<String, Object>) - Method in class org.ovirt.vdsm.jsonrpc.client.ResponseBuilder
-
Adds error
Map
to the response. - withHeader(String, String) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- withHeaders(Map<String, String>) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
- withIgnoreResponseKey() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.JsonResponseUtil
-
During response decomposition we will ignore default key and use raw response structure as result
Map
. - withOptionalParameter(String, Object) - Method in class org.ovirt.vdsm.jsonrpc.client.RequestBuilder
-
Adds parameter which is optional by method runtime and if not provided default value will be used during method execution.
- withOptionalParameter(String, String) - Method in class org.ovirt.vdsm.jsonrpc.client.RequestBuilder
-
Adds parameter which is optional by method runtime and if not provided default value will be used during method execution.
- withOptionalParameterAsList(String, List) - Method in class org.ovirt.vdsm.jsonrpc.client.RequestBuilder
-
Adds
List
of values which is optional by method runtime and if not provided default value will be used during method execution. - withOptionalParameterAsMap(String, Map) - Method in class org.ovirt.vdsm.jsonrpc.client.RequestBuilder
-
Adds
Map
of values which is optional by method runtime and if not provided default value will be used during method execution. - withParameter(String, Object) - Method in class org.ovirt.vdsm.jsonrpc.client.RequestBuilder
-
Adds parameter which is required by method runtime.
- withParameter(String, String) - Method in class org.ovirt.vdsm.jsonrpc.client.RequestBuilder
-
Adds parameter which is required by method runtime.
- withResponseKey(String) - Method in class org.ovirt.vdsm.jsonrpc.client.utils.JsonResponseUtil
- withResponseType(Class<?>) - Method in class org.ovirt.vdsm.jsonrpc.client.utils.JsonResponseUtil
- withResult(String) - Method in class org.ovirt.vdsm.jsonrpc.client.ResponseBuilder
-
Adds result
String
to the response. - withResult(List<Object>) - Method in class org.ovirt.vdsm.jsonrpc.client.ResponseBuilder
-
Adds result
List
to the response. - withResult(Map<String, Object>) - Method in class org.ovirt.vdsm.jsonrpc.client.ResponseBuilder
-
Adds result
Map
to the response. - withSubTypeClazz(Class<?>) - Method in class org.ovirt.vdsm.jsonrpc.client.utils.JsonResponseUtil
- withSubtypeKey(String) - Method in class org.ovirt.vdsm.jsonrpc.client.utils.JsonResponseUtil
- worker - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorFactory
- write(ByteBuffer) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.PlainClient
- write(ByteBuffer) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
-
Writes provided buffer.
- write(ByteBuffer) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLClient
- write(ByteBuffer) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLEngineNioHelper
All Classes All Packages