Uses of Interface
org.infinispan.remoting.transport.ResponseCollector
-
Packages that use ResponseCollector Package Description org.infinispan.interceptors.distribution Interceptors dealing with command replication in distributed/replicated mode.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. -
-
Uses of ResponseCollector in org.infinispan.interceptors.distribution
Subinterfaces of ResponseCollector in org.infinispan.interceptors.distribution Modifier and Type Interface Description interface
BiasedCollector
-
Uses of ResponseCollector in org.infinispan.remoting.rpc
Methods in org.infinispan.remoting.rpc with parameters of type ResponseCollector Modifier and Type Method Description <T> CompletionStage<T>
RpcManager. invokeCommand(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)
Invoke a command on a collection of node and pass the responses to aResponseCollector
.<T> CompletionStage<T>
RpcManager. invokeCommand(Address target, ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)
Invoke a command on a single node and pass the response to aResponseCollector
.<T> CompletionStage<T>
RpcManagerImpl. invokeCommand(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)
<T> CompletionStage<T>
RpcManagerImpl. invokeCommand(Address target, ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)
<T> CompletionStage<T>
RpcManager. invokeCommandOnAll(ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)
Invoke a command on all the nodes in the cluster and pass the responses to aResponseCollector
.<T> CompletionStage<T>
RpcManagerImpl. invokeCommandOnAll(ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)
<T> CompletionStage<T>
RpcManager. invokeCommands(Collection<Address> targets, Function<Address,ReplicableCommand> commandGenerator, ResponseCollector<T> collector, RpcOptions rpcOptions)
Invoke different commands on a collection of nodes and pass the responses to aResponseCollector
.<T> CompletionStage<T>
RpcManagerImpl. invokeCommands(Collection<Address> targets, Function<Address,ReplicableCommand> commandGenerator, ResponseCollector<T> collector, RpcOptions rpcOptions)
<T> CompletionStage<T>
RpcManager. invokeCommandStaggered(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)
Invoke a command on a collection of nodes and pass the responses to aResponseCollector
.<T> CompletionStage<T>
RpcManagerImpl. invokeCommandStaggered(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)
-
Uses of ResponseCollector in org.infinispan.remoting.transport
Classes in org.infinispan.remoting.transport that implement ResponseCollector Modifier and Type Class Description class
RemoteGetResponseCollector
Return the first response that is either successful or exceptional.class
ValidResponseCollector<T>
Base class for response collectors, splitting responses into valid responses, exception responses, and target missing.class
ValidSingleResponseCollector<T>
Fields in org.infinispan.remoting.transport declared as ResponseCollector Modifier and Type Field Description protected ResponseCollector<T>
AbstractRequest. responseCollector
Methods in org.infinispan.remoting.transport with parameters of type ResponseCollector Modifier and Type Method Description <T> CompletionStage<T>
AbstractDelegatingTransport. invokeCommand(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, TimeUnit unit)
<T> CompletionStage<T>
AbstractDelegatingTransport. invokeCommand(Address target, ReplicableCommand command, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, TimeUnit unit)
default <T> CompletionStage<T>
Transport. invokeCommand(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, TimeUnit unit)
Invoke a command on a collection of node and pass the responses to aResponseCollector
.default <T> CompletionStage<T>
Transport. invokeCommand(Address target, ReplicableCommand command, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, TimeUnit unit)
Invoke a command on a single node and pass the response to aResponseCollector
.<T> CompletionStage<T>
AbstractDelegatingTransport. invokeCommandOnAll(ReplicableCommand command, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, TimeUnit unit)
default <T> CompletionStage<T>
Transport. invokeCommandOnAll(Collection<Address> requiredTargets, ReplicableCommand command, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, TimeUnit unit)
Invoke a command on all the nodes in the cluster and pass the responses to aResponseCollector
.default <T> CompletionStage<T>
Transport. invokeCommandOnAll(ReplicableCommand command, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, TimeUnit unit)
Invoke a command on all the nodes in the cluster and pass the responses to aResponseCollector
.<T> CompletionStage<T>
AbstractDelegatingTransport. invokeCommands(Collection<Address> targets, Function<Address,ReplicableCommand> commandGenerator, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, TimeUnit timeUnit)
default <T> CompletionStage<T>
Transport. invokeCommands(Collection<Address> targets, Function<Address,ReplicableCommand> commandGenerator, ResponseCollector<T> responseCollector, long timeout, DeliverOrder deliverOrder)
Deprecated.Introduced in 9.1, but replaced in 9.2 withTransport.invokeCommands(Collection, Function, ResponseCollector, DeliverOrder, long, TimeUnit)
.default <T> CompletionStage<T>
Transport. invokeCommands(Collection<Address> targets, Function<Address,ReplicableCommand> commandGenerator, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, TimeUnit timeUnit)
Invoke different commands on a collection of nodes and pass the responses to aResponseCollector
.<T> CompletionStage<T>
AbstractDelegatingTransport. invokeCommandStaggered(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, TimeUnit unit)
default <T> CompletionStage<T>
Transport. invokeCommandStaggered(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, TimeUnit unit)
Invoke a command on a collection of nodes and pass the responses to aResponseCollector
.Constructors in org.infinispan.remoting.transport with parameters of type ResponseCollector Constructor Description AbstractRequest(long requestId, ResponseCollector<T> responseCollector, RequestRepository repository)
-
Uses of ResponseCollector in org.infinispan.remoting.transport.impl
Classes in org.infinispan.remoting.transport.impl that implement ResponseCollector Modifier and Type Class Description class
FilterMapResponseCollector
class
MapResponseCollector
class
PassthroughMapResponseCollector
Receive responses from multiple nodes, without checking that the responses are valid.class
PassthroughSingleResponseCollector
RPC to a single node, without any validity checks.class
SingleResponseCollector
Response collector for a single response.class
SingletonMapResponseCollector
class
VoidResponseCollector
Response collector that discards successful responses and returnsnull
.Constructors in org.infinispan.remoting.transport.impl with parameters of type ResponseCollector Constructor Description MultiTargetRequest(ResponseCollector<T> responseCollector, long requestId, RequestRepository repository, Collection<Address> targets, Address excluded)
SingleTargetRequest(ResponseCollector<T> wrapper, long requestId, RequestRepository repository, Address target)
-
Uses of ResponseCollector in org.infinispan.remoting.transport.jgroups
Methods in org.infinispan.remoting.transport.jgroups with parameters of type ResponseCollector Modifier and Type Method Description <T> CompletionStage<T>
JGroupsTransport. invokeCommand(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, TimeUnit unit)
<T> CompletionStage<T>
JGroupsTransport. invokeCommand(Address target, ReplicableCommand command, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, TimeUnit unit)
<T> CompletionStage<T>
JGroupsTransport. invokeCommandOnAll(Collection<Address> requiredTargets, ReplicableCommand command, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, TimeUnit unit)
<T> CompletionStage<T>
JGroupsTransport. invokeCommandOnAll(ReplicableCommand command, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, TimeUnit unit)
<T> CompletionStage<T>
JGroupsTransport. invokeCommands(Collection<Address> targets, Function<Address,ReplicableCommand> commandGenerator, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, TimeUnit timeUnit)
<T> CompletionStage<T>
JGroupsTransport. invokeCommandStaggered(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, TimeUnit unit)
-