Uses of Class
org.infinispan.remoting.rpc.RpcOptions
-
Packages that use RpcOptions Package Description org.infinispan.remoting.rpc Remote Procedure Call (RPC) interfaces and components used to invoke remote methods on cache instances.org.infinispan.statetransfer Transfer of state to new caches in a cluster.org.infinispan.stats.wrappers -
-
Uses of RpcOptions in org.infinispan.remoting.rpc
Methods in org.infinispan.remoting.rpc that return RpcOptions Modifier and Type Method Description RpcOptions
RpcOptionsBuilder. build()
Deprecated.RpcOptions
RpcManager. getDefaultRpcOptions(boolean sync)
Deprecated.Since 9.2, please useRpcManager.getSyncRpcOptions()
instead.RpcOptions
RpcManager. getDefaultRpcOptions(boolean sync, DeliverOrder deliverOrder)
Deprecated.Since 9.2, please useRpcManager.getSyncRpcOptions()
orRpcManager.getTotalSyncRpcOptions()
instead.RpcOptions
RpcManagerImpl. getDefaultRpcOptions(boolean sync)
RpcOptions
RpcManagerImpl. getDefaultRpcOptions(boolean sync, DeliverOrder deliverOrder)
RpcOptions
RpcManager. getSyncRpcOptions()
RpcOptions
RpcManagerImpl. getSyncRpcOptions()
RpcOptions
RpcManager. getTotalSyncRpcOptions()
RpcOptions
RpcManagerImpl. getTotalSyncRpcOptions()
Methods in org.infinispan.remoting.rpc with parameters of type RpcOptions 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 aResponseCollector
.<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 aResponseCollector
.<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 aResponseCollector
.<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 aResponseCollector
.<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 aResponseCollector
.<T> java.util.concurrent.CompletionStage<T>
RpcManagerImpl. invokeCommandStaggered(java.util.Collection<Address> targets, org.infinispan.commands.ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)
java.util.Map<Address,Response>
RpcManager. invokeRemotely(java.util.Collection<Address> recipients, org.infinispan.commands.ReplicableCommand rpc, RpcOptions options)
Deprecated.Since 9.2, please useRpcManager.invokeCommand(Collection, ReplicableCommand, ResponseCollector, RpcOptions)
instead.java.util.Map<Address,Response>
RpcManager. invokeRemotely(java.util.Map<Address,org.infinispan.commands.ReplicableCommand> rpcs, RpcOptions options)
Deprecated.Since 9.2, please useRpcManager.invokeCommands(Collection, Function, ResponseCollector, RpcOptions)
instead.java.util.Map<Address,Response>
RpcManagerImpl. invokeRemotely(java.util.Collection<Address> recipients, org.infinispan.commands.ReplicableCommand rpc, RpcOptions options)
java.util.Map<Address,Response>
RpcManagerImpl. invokeRemotely(java.util.Map<Address,org.infinispan.commands.ReplicableCommand> rpcs, RpcOptions options)
java.util.concurrent.CompletableFuture<java.util.Map<Address,Response>>
RpcManager. invokeRemotelyAsync(java.util.Collection<Address> recipients, org.infinispan.commands.ReplicableCommand rpc, RpcOptions options)
Invokes a command on remote nodes.java.util.concurrent.CompletableFuture<java.util.Map<Address,Response>>
RpcManagerImpl. invokeRemotelyAsync(java.util.Collection<Address> recipients, org.infinispan.commands.ReplicableCommand rpc, RpcOptions options)
Constructors in org.infinispan.remoting.rpc with parameters of type RpcOptions Constructor Description RpcOptionsBuilder(RpcOptions template)
Deprecated.Constructor based on existingRpcOptions
-
Uses of RpcOptions in org.infinispan.statetransfer
Fields in org.infinispan.statetransfer declared as RpcOptions Modifier and Type Field Description protected RpcOptions
StateConsumerImpl. rpcOptions
-
Uses of RpcOptions in org.infinispan.stats.wrappers
Methods in org.infinispan.stats.wrappers that return RpcOptions Modifier and Type Method Description RpcOptions
ExtendedStatisticRpcManager. getDefaultRpcOptions(boolean sync)
RpcOptions
ExtendedStatisticRpcManager. getDefaultRpcOptions(boolean sync, DeliverOrder deliverOrder)
RpcOptions
ExtendedStatisticRpcManager. getSyncRpcOptions()
RpcOptions
ExtendedStatisticRpcManager. getTotalSyncRpcOptions()
Methods in org.infinispan.stats.wrappers with parameters of type RpcOptions 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)
java.util.Map<Address,Response>
ExtendedStatisticRpcManager. invokeRemotely(java.util.Collection<Address> recipients, org.infinispan.commands.ReplicableCommand rpc, RpcOptions options)
java.util.Map<Address,Response>
ExtendedStatisticRpcManager. invokeRemotely(java.util.Map<Address,org.infinispan.commands.ReplicableCommand> rpcs, RpcOptions options)
java.util.concurrent.CompletableFuture<java.util.Map<Address,Response>>
ExtendedStatisticRpcManager. invokeRemotelyAsync(java.util.Collection<Address> recipients, org.infinispan.commands.ReplicableCommand rpc, RpcOptions options)
-