Uses of Interface
org.infinispan.remoting.responses.Response
-
Packages that use Response Package Description org.infinispan.interceptors.distribution Interceptors dealing with command replication in distributed/replicated mode.org.infinispan.interceptors.impl Basic interceptorsorg.infinispan.remoting Remote communication between cache instances.org.infinispan.remoting.inboundhandler Handling of inbound commands on remote nodes.org.infinispan.remoting.responses Abstractions of the different response types allowed during RPC.org.infinispan.remoting.rpc Remote Procedure Call (RPC) interfaces and components used to invoke remote methods on cache instances.org.infinispan.remoting.transport Transports handle the low-level networking, used by the remoting components.org.infinispan.remoting.transport.impl org.infinispan.remoting.transport.jgroups A transport implementation based on JGroups.org.infinispan.statetransfer Transfer of state to new caches in a cluster.org.infinispan.stats.wrappers org.infinispan.transaction.impl org.infinispan.util.logging Infinispan's logging abstractions that delegate to either JDK or Log4J logging engines. -
-
Uses of Response in org.infinispan.interceptors.distribution
Methods in org.infinispan.interceptors.distribution with parameters of type Response Modifier and Type Method Description default ValidResponse
BiasedCollector. addResponse(Address sender, Response response)
SuccessfulResponse
RemoteGetSingleKeyCollector. addResponse(Address sender, Response response)
Method parameters in org.infinispan.interceptors.distribution with type arguments of type Response Modifier and Type Method Description protected void
TxDistributionInterceptor. checkTxCommandResponses(Map<Address,Response> responseMap, org.infinispan.commands.tx.TransactionBoundaryCommand command, TxInvocationContext<LocalTransaction> context, Collection<Address> recipients)
-
Uses of Response in org.infinispan.interceptors.impl
Methods in org.infinispan.interceptors.impl with parameters of type Response Modifier and Type Method Description protected static RuntimeException
ClusteringInterceptor. unexpected(Response response)
Method parameters in org.infinispan.interceptors.impl with type arguments of type Response Modifier and Type Method Description protected static SuccessfulResponse
ClusteringInterceptor. getSuccessfulResponseOrFail(Map<Address,Response> responseMap, CompletableFuture<?> future, Consumer<Response> cacheNotFound)
protected static SuccessfulResponse
ClusteringInterceptor. getSuccessfulResponseOrFail(Map<Address,Response> responseMap, CompletableFuture<?> future, Consumer<Response> cacheNotFound)
-
Uses of Response in org.infinispan.remoting
Methods in org.infinispan.remoting that return Response Modifier and Type Method Description Response
LocalInvocation. apply(Object retVal)
Response
LocalInvocation. call()
Methods in org.infinispan.remoting that return types with arguments of type Response Modifier and Type Method Description CompletableFuture<Response>
LocalInvocation. callAsync()
-
Uses of Response in org.infinispan.remoting.inboundhandler
Fields in org.infinispan.remoting.inboundhandler declared as Response Modifier and Type Field Description protected Response
BaseBlockingRunnable. response
Methods in org.infinispan.remoting.inboundhandler that return types with arguments of type Response Modifier and Type Method Description protected CompletableFuture<Response>
BaseBlockingRunnable. beforeInvoke()
protected CompletableFuture<Response>
DefaultTopologyRunnable. beforeInvoke()
Methods in org.infinispan.remoting.inboundhandler with parameters of type Response Modifier and Type Method Description void
Reply. reply(Response response)
Sends back the return value to the sender. -
Uses of Response in org.infinispan.remoting.responses
Classes in org.infinispan.remoting.responses that implement Response Modifier and Type Class Description class
BiasRevocationResponse
class
CacheNotFoundResponse
A response that signals the named cache is not running on the target node.class
ExceptionResponse
A response that encapsulates an exceptionclass
InvalidResponse
An invalid responseclass
SuccessfulResponse
A successful responseclass
UnsuccessfulResponse
An unsuccessful responseclass
UnsureResponse
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
ValidResponse
A valid responseMethods in org.infinispan.remoting.responses that return Response Modifier and Type Method Description Response
DefaultResponseGenerator. getResponse(org.infinispan.commands.remote.CacheRpcCommand command, Object returnValue)
Response
ResponseGenerator. getResponse(org.infinispan.commands.remote.CacheRpcCommand command, Object returnValue)
Methods in org.infinispan.remoting.responses with parameters of type Response Modifier and Type Method Description boolean
ClusteredGetResponseValidityFilter. isAcceptable(Response response, Address address)
boolean
IgnoreExtraResponsesValidityFilter. isAcceptable(Response response, Address address)
-
Uses of Response in org.infinispan.remoting.rpc
Methods in org.infinispan.remoting.rpc with parameters of type Response Modifier and Type Method Description boolean
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
Methods in org.infinispan.remoting.transport that return Response Modifier and Type Method Description Response
AbstractTransport. checkResponse(Object responseObject, Address sender, boolean ignoreCacheNotFoundResponse)
Deprecated.Methods in org.infinispan.remoting.transport that return types with arguments of type Response Modifier and Type Method Description protected Map<Address,Response>
AbstractDelegatingTransport. afterInvokeRemotely(ReplicableCommand command, Map<Address,Response> responseMap)
method invoked after a successful remote invocation.Map<Address,Response>
AbstractDelegatingTransport. invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, ResponseFilter responseFilter, DeliverOrder deliverOrder, boolean anycast)
Map<Address,Response>
AbstractDelegatingTransport. invokeRemotely(Map<Address,ReplicableCommand> rpcCommands, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter, boolean totalOrder, boolean anycast)
Map<Address,Response>
AbstractDelegatingTransport. invokeRemotely(Map<Address,ReplicableCommand> rpcCommands, ResponseMode mode, long timeout, ResponseFilter responseFilter, DeliverOrder deliverOrder, boolean anycast)
default Map<Address,Response>
Transport. invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, ResponseFilter responseFilter, DeliverOrder deliverOrder, boolean anycast)
Deprecated.Since 9.2, please useTransport.invokeCommand(Collection, ReplicableCommand, ResponseCollector, DeliverOrder, long, TimeUnit)
instead.default Map<Address,Response>
Transport. invokeRemotely(Map<Address,ReplicableCommand> rpcCommands, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter, boolean totalOrder, boolean anycast)
Deprecated.default Map<Address,Response>
Transport. invokeRemotely(Map<Address,ReplicableCommand> rpcCommands, ResponseMode mode, long timeout, ResponseFilter responseFilter, DeliverOrder deliverOrder, boolean anycast)
Deprecated.Since 9.2, please useTransport.invokeRemotelyAsync(Collection, ReplicableCommand, ResponseMode, long, ResponseFilter, DeliverOrder, boolean)
instead.CompletableFuture<Map<Address,Response>>
AbstractDelegatingTransport. invokeRemotelyAsync(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, ResponseFilter responseFilter, DeliverOrder deliverOrder, boolean anycast)
CompletableFuture<Map<Address,Response>>
Transport. invokeRemotelyAsync(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, ResponseFilter responseFilter, DeliverOrder deliverOrder, boolean anycast)
Methods in org.infinispan.remoting.transport with parameters of type Response Modifier and Type Method Description T
ResponseCollector. addResponse(Address sender, Response response)
Called when a response is received, or when a target node becomes unavailable.T
ValidResponseCollector. addResponse(Address sender, Response response)
T
ValidSingleResponseCollector. addResponse(Address sender, Response response)
static RuntimeException
ResponseCollectors. unexpectedResponse(Response response)
Method parameters in org.infinispan.remoting.transport with type arguments of type Response Modifier and Type Method Description protected Map<Address,Response>
AbstractDelegatingTransport. afterInvokeRemotely(ReplicableCommand command, Map<Address,Response> responseMap)
method invoked after a successful remote invocation. -
Uses of Response in org.infinispan.remoting.transport.impl
Fields in org.infinispan.remoting.transport.impl with type parameters of type Response Modifier and Type Field Description protected HashMap<Address,Response>
MapResponseCollector. map
Methods in org.infinispan.remoting.transport.impl that return Response Modifier and Type Method Description Response
PassthroughSingleResponseCollector. addResponse(Address sender, Response response)
Response
PassthroughSingleResponseCollector. finish()
Methods in org.infinispan.remoting.transport.impl that return types with arguments of type Response Modifier and Type Method Description protected Map<Address,Response>
FilterMapResponseCollector. addException(Address sender, Exception exception)
protected Map<Address,Response>
MapResponseCollector. addException(Address sender, Exception exception)
Map<Address,Response>
PassthroughMapResponseCollector. addResponse(Address sender, Response response)
protected Map<Address,Response>
FilterMapResponseCollector. addTargetNotFound(Address sender)
protected Map<Address,Response>
FilterMapResponseCollector. addValidResponse(Address sender, ValidResponse response)
protected Map<Address,Response>
MapResponseCollector. addValidResponse(Address sender, ValidResponse response)
Map<Address,Response>
FilterMapResponseCollector. finish()
Map<Address,Response>
MapResponseCollector. finish()
Map<Address,Response>
PassthroughMapResponseCollector. finish()
protected Map<Address,Response>
SingletonMapResponseCollector. targetNotFound(Address sender)
protected Map<Address,Response>
SingletonMapResponseCollector. withValidResponse(Address sender, ValidResponse response)
Methods in org.infinispan.remoting.transport.impl with parameters of type Response Modifier and Type Method Description Map<Address,Response>
PassthroughMapResponseCollector. addResponse(Address sender, Response 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
Methods in org.infinispan.remoting.transport.jgroups that return types with arguments of type Response Modifier and Type Method Description Map<Address,Response>
JGroupsTransport. invokeRemotely(Map<Address,ReplicableCommand> commands, ResponseMode mode, long timeout, ResponseFilter responseFilter, DeliverOrder deliverOrder, boolean anycast)
Deprecated.CompletableFuture<Map<Address,Response>>
JGroupsTransport. invokeRemotelyAsync(Collection<Address> recipients, ReplicableCommand command, ResponseMode mode, long timeout, ResponseFilter responseFilter, DeliverOrder deliverOrder, boolean anycast)
Methods in org.infinispan.remoting.transport.jgroups with parameters of type Response Modifier and Type Method Description void
SingleSiteRequest. onResponse(Address sender, Response response)
void
StaggeredRequest. onResponse(Address sender, Response response)
-
Uses of Response in org.infinispan.statetransfer
Methods in org.infinispan.statetransfer that return types with arguments of type Response Modifier and Type Method Description Map<Address,Response>
StateTransferManager. forwardCommandIfNeeded(TopologyAffectedCommand command, Set<Object> affectedKeys, Address origin)
If there is an state transfer happening at the moment, this method forwards the supplied command to the nodes that are new owners of the data, in order to assure consistency.Map<Address,Response>
StateTransferManagerImpl. forwardCommandIfNeeded(TopologyAffectedCommand command, Set<Object> affectedKeys, Address origin)
-
Uses of Response in org.infinispan.stats.wrappers
Methods in org.infinispan.stats.wrappers that return types with arguments of type Response Modifier and Type Method Description Map<Address,Response>
ExtendedStatisticRpcManager. invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, RpcOptions options)
Map<Address,Response>
ExtendedStatisticRpcManager. invokeRemotely(Map<Address,ReplicableCommand> rpcs, RpcOptions options)
CompletableFuture<Map<Address,Response>>
ExtendedStatisticRpcManager. invokeRemotelyAsync(Collection<Address> recipients, ReplicableCommand rpc, RpcOptions options)
-
Uses of Response in org.infinispan.transaction.impl
Methods in org.infinispan.transaction.impl with parameters of type Response Modifier and Type Method Description static void
WriteSkewHelper. readVersionsFromResponse(Response r, CacheTransaction ct)
-
Uses of Response in org.infinispan.util.logging
Methods in org.infinispan.util.logging with parameters of type Response Modifier and Type Method Description void
Log_$logger. unsuccessfulResponseForClusterListeners(Address address, Response response)
void
Log. unsuccessfulResponseForClusterListeners(Address address, Response response)
void
Log_$logger. unsuccessfulResponseRetrievingTransactionsForSegments(Address address, Response response)
void
Log. unsuccessfulResponseRetrievingTransactionsForSegments(Address address, Response response)
Method parameters in org.infinispan.util.logging with type arguments of type Response Modifier and Type Method Description void
Log_$logger. expectedJustOneResponse(Map<Address,Response> lr)
void
Log. expectedJustOneResponse(Map<Address,Response> lr)
void
Log_$logger. unknownResponsesFromRemoteCache(Collection<Response> responses)
void
Log. unknownResponsesFromRemoteCache(Collection<Response> responses)
-