Uses of Interface
org.infinispan.remoting.transport.ResponseCollector

Packages that use ResponseCollector

Package	Description
org.infinispan.extendedstats.wrappers
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.jgroups	A transport implementation based on JGroups.

Uses of ResponseCollector in org.infinispan.extendedstats.wrappers

Methods in org.infinispan.extendedstats.wrappers with parameters of type ResponseCollector

Modifier and Type	Method	Description
<T> java.util.concurrent.CompletionStage<T>	ExtendedStatisticRpcManager.invokeCommand(java.util.Collection<Address> targets, org.infinispan.commands.ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)
<T> java.util.concurrent.CompletionStage<T>	ExtendedStatisticRpcManager.invokeCommand(Address target, org.infinispan.commands.ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)
<T> java.util.concurrent.CompletionStage<T>	ExtendedStatisticRpcManager.invokeCommandOnAll(org.infinispan.commands.ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)
<T> java.util.concurrent.CompletionStage<T>	ExtendedStatisticRpcManager.invokeCommands(java.util.Collection<Address> targets, java.util.function.Function<Address,org.infinispan.commands.ReplicableCommand> commandGenerator, ResponseCollector<T> collector, RpcOptions rpcOptions)
<T> java.util.concurrent.CompletionStage<T>	ExtendedStatisticRpcManager.invokeCommandStaggered(java.util.Collection<Address> targets, org.infinispan.commands.ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)

Uses of ResponseCollector in org.infinispan.interceptors.distribution

Subinterfaces of ResponseCollector in org.infinispan.interceptors.distribution

Modifier and Type	Interface	Description
interface	BiasedCollector

Classes in org.infinispan.interceptors.distribution that implement ResponseCollector

Modifier and Type	Class	Description
class	RemoteGetSingleKeyCollector	Return the first successful response for a staggered remote get, used in dist mode.

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> java.util.concurrent.CompletionStage<T>	RpcManager.invokeCommand(java.util.Collection<Address> targets, org.infinispan.commands.ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)	Invoke a command on a collection of node and pass the responses to a ResponseCollector.
<T> java.util.concurrent.CompletionStage<T>	RpcManager.invokeCommand(Address target, org.infinispan.commands.ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)	Invoke a command on a single node and pass the response to a ResponseCollector.
<T> java.util.concurrent.CompletionStage<T>	RpcManagerImpl.invokeCommand(java.util.Collection<Address> targets, org.infinispan.commands.ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)
<T> java.util.concurrent.CompletionStage<T>	RpcManagerImpl.invokeCommand(Address target, org.infinispan.commands.ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)
<T> java.util.concurrent.CompletionStage<T>	RpcManager.invokeCommandOnAll(org.infinispan.commands.ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)	Invoke a command on all the nodes in the cluster and pass the responses to a ResponseCollector.
<T> java.util.concurrent.CompletionStage<T>	RpcManagerImpl.invokeCommandOnAll(org.infinispan.commands.ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)
<T> java.util.concurrent.CompletionStage<T>	RpcManager.invokeCommands(java.util.Collection<Address> targets, java.util.function.Function<Address,org.infinispan.commands.ReplicableCommand> commandGenerator, ResponseCollector<T> collector, RpcOptions rpcOptions)	Invoke different commands on a collection of nodes and pass the responses to a ResponseCollector.
<T> java.util.concurrent.CompletionStage<T>	RpcManagerImpl.invokeCommands(java.util.Collection<Address> targets, java.util.function.Function<Address,org.infinispan.commands.ReplicableCommand> commandGenerator, ResponseCollector<T> collector, RpcOptions rpcOptions)
<T> java.util.concurrent.CompletionStage<T>	RpcManager.invokeCommandStaggered(java.util.Collection<Address> targets, org.infinispan.commands.ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)	Invoke a command on a collection of nodes and pass the responses to a ResponseCollector.
<T> java.util.concurrent.CompletionStage<T>	RpcManagerImpl.invokeCommandStaggered(java.util.Collection<Address> targets, org.infinispan.commands.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	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> java.util.concurrent.CompletionStage<T>	AbstractDelegatingTransport.invokeCommand(java.util.Collection<Address> targets, org.infinispan.commands.ReplicableCommand command, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, java.util.concurrent.TimeUnit unit)
<T> java.util.concurrent.CompletionStage<T>	AbstractDelegatingTransport.invokeCommand(Address target, org.infinispan.commands.ReplicableCommand command, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, java.util.concurrent.TimeUnit unit)
default <T> java.util.concurrent.CompletionStage<T>	Transport.invokeCommand(java.util.Collection<Address> targets, org.infinispan.commands.ReplicableCommand command, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, java.util.concurrent.TimeUnit unit)	Invoke a command on a collection of node and pass the responses to a ResponseCollector.
default <T> java.util.concurrent.CompletionStage<T>	Transport.invokeCommand(Address target, org.infinispan.commands.ReplicableCommand command, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, java.util.concurrent.TimeUnit unit)	Invoke a command on a single node and pass the response to a ResponseCollector.
<T> java.util.concurrent.CompletionStage<T>	AbstractDelegatingTransport.invokeCommandOnAll(org.infinispan.commands.ReplicableCommand command, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, java.util.concurrent.TimeUnit unit)
default <T> java.util.concurrent.CompletionStage<T>	Transport.invokeCommandOnAll(java.util.Collection<Address> requiredTargets, org.infinispan.commands.ReplicableCommand command, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, java.util.concurrent.TimeUnit unit)	Invoke a command on all the nodes in the cluster and pass the responses to a ResponseCollector.
default <T> java.util.concurrent.CompletionStage<T>	Transport.invokeCommandOnAll(org.infinispan.commands.ReplicableCommand command, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, java.util.concurrent.TimeUnit unit)	Invoke a command on all the nodes in the cluster and pass the responses to a ResponseCollector.
<T> java.util.concurrent.CompletionStage<T>	AbstractDelegatingTransport.invokeCommands(java.util.Collection<Address> targets, java.util.function.Function<Address,org.infinispan.commands.ReplicableCommand> commandGenerator, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, java.util.concurrent.TimeUnit timeUnit)
default <T> java.util.concurrent.CompletionStage<T>	Transport.invokeCommands(java.util.Collection<Address> targets, java.util.function.Function<Address,org.infinispan.commands.ReplicableCommand> commandGenerator, ResponseCollector<T> responseCollector, long timeout, DeliverOrder deliverOrder)	Deprecated. Introduced in 9.1, but replaced in 9.2 with Transport.invokeCommands(Collection, Function, ResponseCollector, DeliverOrder, long, TimeUnit).
default <T> java.util.concurrent.CompletionStage<T>	Transport.invokeCommands(java.util.Collection<Address> targets, java.util.function.Function<Address,org.infinispan.commands.ReplicableCommand> commandGenerator, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, java.util.concurrent.TimeUnit timeUnit)	Invoke different commands on a collection of nodes and pass the responses to a ResponseCollector.
<T> java.util.concurrent.CompletionStage<T>	AbstractDelegatingTransport.invokeCommandStaggered(java.util.Collection<Address> targets, org.infinispan.commands.ReplicableCommand command, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, java.util.concurrent.TimeUnit unit)
default <T> java.util.concurrent.CompletionStage<T>	Transport.invokeCommandStaggered(java.util.Collection<Address> targets, org.infinispan.commands.ReplicableCommand command, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, java.util.concurrent.TimeUnit unit)	Invoke a command on a collection of nodes and pass the responses to a ResponseCollector.

Constructors in org.infinispan.remoting.transport with parameters of type ResponseCollector

Constructor	Description
AbstractRequest(long requestId, ResponseCollector<T> responseCollector, org.infinispan.remoting.transport.impl.RequestRepository repository)

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> java.util.concurrent.CompletionStage<T>	JGroupsTransport.invokeCommand(java.util.Collection<Address> targets, org.infinispan.commands.ReplicableCommand command, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, java.util.concurrent.TimeUnit unit)
<T> java.util.concurrent.CompletionStage<T>	JGroupsTransport.invokeCommand(Address target, org.infinispan.commands.ReplicableCommand command, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, java.util.concurrent.TimeUnit unit)
<T> java.util.concurrent.CompletionStage<T>	JGroupsTransport.invokeCommandOnAll(java.util.Collection<Address> requiredTargets, org.infinispan.commands.ReplicableCommand command, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, java.util.concurrent.TimeUnit unit)
<T> java.util.concurrent.CompletionStage<T>	JGroupsTransport.invokeCommandOnAll(org.infinispan.commands.ReplicableCommand command, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, java.util.concurrent.TimeUnit unit)
<T> java.util.concurrent.CompletionStage<T>	JGroupsTransport.invokeCommands(java.util.Collection<Address> targets, java.util.function.Function<Address,org.infinispan.commands.ReplicableCommand> commandGenerator, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, java.util.concurrent.TimeUnit timeUnit)
<T> java.util.concurrent.CompletionStage<T>	JGroupsTransport.invokeCommandStaggered(java.util.Collection<Address> targets, org.infinispan.commands.ReplicableCommand command, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, java.util.concurrent.TimeUnit unit)