Uses of Interface
org.infinispan.remoting.responses.Response
Package
Description
Remote communication between cache instances.
Abstractions of the different response types allowed during RPC.
Remote Procedure Call (RPC) interfaces and components used to invoke remote methods on cache instances.
Transports handle the low-level networking, used by the remoting components.
A transport implementation based on JGroups.
-
Uses of Response in org.infinispan.extendedstats.wrappers
Modifier and TypeMethodDescriptionExtendedStatisticRpcManager.invokeRemotelyAsync
(Collection<Address> recipients, ReplicableCommand rpc, RpcOptions options) -
Uses of Response in org.infinispan.remoting
-
Uses of Response in org.infinispan.remoting.responses
Modifier and TypeClassDescriptionclass
class
A response that signals the named cache is not running on the target node.class
A response that encapsulates an exceptionclass
An invalid responseclass
AValidResponse
used by Optimistic Transactions.class
A successful responseclass
An unsuccessful responseclass
An unsure response - used with Dist - essentially asks the caller to check the next response from the next node since the sender is in a state of flux (probably in the middle of rebalancing)class
A valid responseModifier and TypeMethodDescriptionDefaultResponseGenerator.getResponse
(org.infinispan.commands.remote.CacheRpcCommand command, Object returnValue) ResponseGenerator.getResponse
(org.infinispan.commands.remote.CacheRpcCommand command, Object returnValue) Modifier and TypeMethodDescriptionboolean
ClusteredGetResponseValidityFilter.isAcceptable
(Response response, Address address) boolean
IgnoreExtraResponsesValidityFilter.isAcceptable
(Response response, Address address) -
Uses of Response in org.infinispan.remoting.rpc
Modifier and TypeMethodDescriptiondefault CompletableFuture<Map<Address,
Response>> RpcManager.invokeRemotelyAsync
(Collection<Address> recipients, ReplicableCommand rpc, RpcOptions options) Deprecated, for removal: This API element is subject to removal in a future version.RpcManagerImpl.invokeRemotelyAsync
(Collection<Address> recipients, ReplicableCommand rpc, RpcOptions options) Modifier and TypeMethodDescriptionboolean
ResponseFilter.isAcceptable
(Response response, Address sender) Determines whether a response from a given sender should be added to the response list of the request -
Uses of Response in org.infinispan.remoting.transport
Modifier and TypeMethodDescriptionAbstractTransport.checkResponse
(Object responseObject, Address sender, boolean ignoreCacheNotFoundResponse) Deprecated, for removal: This API element is subject to removal in a future version.Modifier and TypeMethodDescriptionAbstractDelegatingTransport.invokeRemotely
(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, ResponseFilter responseFilter, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, boolean anycast) Deprecated, for removal: This API element is subject to removal in a future version.AbstractDelegatingTransport.invokeRemotely
(Map<Address, ReplicableCommand> rpcCommands, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter, boolean totalOrder, boolean anycast) Deprecated, for removal: This API element is subject to removal in a future version.AbstractDelegatingTransport.invokeRemotely
(Map<Address, ReplicableCommand> rpcCommands, ResponseMode mode, long timeout, ResponseFilter responseFilter, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, boolean anycast) Deprecated, for removal: This API element is subject to removal in a future version.Transport.invokeRemotely
(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, ResponseFilter responseFilter, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, boolean anycast) Deprecated, for removal: This API element is subject to removal in a future version.Since 9.2, please useTransport.invokeCommand(Collection, ReplicableCommand, ResponseCollector, DeliverOrder, long, TimeUnit)
instead.Transport.invokeRemotely
(Map<Address, ReplicableCommand> rpcCommands, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter, boolean totalOrder, boolean anycast) Deprecated, for removal: This API element is subject to removal in a future version.Transport.invokeRemotely
(Map<Address, ReplicableCommand> rpcCommands, ResponseMode mode, long timeout, ResponseFilter responseFilter, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, boolean anycast) Deprecated, for removal: This API element is subject to removal in a future version.Since 9.2, please useTransport.invokeRemotelyAsync(Collection, ReplicableCommand, ResponseMode, long, ResponseFilter, DeliverOrder, boolean)
instead.AbstractDelegatingTransport.invokeRemotelyAsync
(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, ResponseFilter responseFilter, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, boolean anycast) Transport.invokeRemotelyAsync
(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, ResponseFilter responseFilter, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, boolean anycast) Modifier and TypeMethodDescriptionResponseCollector.addResponse
(Address sender, Response response) Called when a response is received, or when a target node becomes unavailable.final T
ValidResponseCollector.addResponse
(Address sender, Response response) final T
ValidSingleResponseCollector.addResponse
(Address sender, Response response) -
Uses of Response in org.infinispan.remoting.transport.impl
Modifier and TypeMethodDescriptionPassthroughSingleResponseCollector.addResponse
(Address sender, Response response) PassthroughSingleResponseCollector.finish()
Modifier and TypeMethodDescriptionFilterMapResponseCollector.addException
(Address sender, Exception exception) MapResponseCollector.addException
(Address sender, Exception exception) PassthroughMapResponseCollector.addResponse
(Address sender, Response response) FilterMapResponseCollector.addTargetNotFound
(Address sender) FilterMapResponseCollector.addValidResponse
(Address sender, ValidResponse response) MapResponseCollector.addValidResponse
(Address sender, ValidResponse response) FilterMapResponseCollector.finish()
MapResponseCollector.finish()
PassthroughMapResponseCollector.finish()
SingletonMapResponseCollector.targetNotFound
(Address sender) SingletonMapResponseCollector.withValidResponse
(Address sender, ValidResponse response) Modifier and TypeMethodDescriptionPassthroughMapResponseCollector.addResponse
(Address sender, Response response) PassthroughSingleResponseCollector.addResponse
(Address sender, Response response) void
RequestRepository.addResponse
(long requestId, Address sender, Response response) void
MultiTargetRequest.onResponse
(Address sender, Response response) void
Request.onResponse
(Address sender, Response response) Called when a response is received for this response.void
SingleTargetRequest.onResponse
(Address sender, Response response) -
Uses of Response in org.infinispan.remoting.transport.jgroups
Modifier and TypeMethodDescriptionJGroupsTransport.invokeRemotely
(Map<Address, ReplicableCommand> commands, ResponseMode mode, long timeout, ResponseFilter responseFilter, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, boolean anycast) Deprecated, for removal: This API element is subject to removal in a future version.JGroupsTransport.invokeRemotelyAsync
(Collection<Address> recipients, ReplicableCommand command, ResponseMode mode, long timeout, ResponseFilter responseFilter, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, boolean anycast) Modifier and TypeMethodDescriptionvoid
SingleSiteRequest.onResponse
(Address sender, Response response) void
StaggeredRequest.onResponse
(Address sender, Response response) -
Uses of Response in org.infinispan.transaction.impl
Modifier and TypeMethodDescriptionstatic void
WriteSkewHelper.mergePrepareResponses
(Response r, PrepareResponse aggregateResponse) -
Uses of Response in org.infinispan.xsite.response
Modifier and TypeClassDescriptionclass
AResponse
implementation for commandXSiteAutoTransferStatusCommand
.Modifier and TypeMethodDescriptionAutoStateTransferResponseCollector.addResponse
(Address sender, Response response)
RpcManager.sendToMany(Collection, ReplicableCommand, DeliverOrder)
orRpcManager.invokeCommand(Collection, ReplicableCommand, ResponseCollector, RpcOptions)
instead.