Uses of Class
org.infinispan.remoting.inboundhandler.DeliverOrder
-
Packages that use DeliverOrder Package Description org.infinispan.remoting.inboundhandler Handling of inbound commands on remote nodes.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 DeliverOrder in org.infinispan.remoting.inboundhandler
Methods in org.infinispan.remoting.inboundhandler that return DeliverOrder Modifier and Type Method Description static DeliverOrder
DeliverOrder. valueOf(String name)
Returns the enum constant of this type with the specified name.static DeliverOrder[]
DeliverOrder. values()
Returns an array containing the constants of this enum type, in the order they are declared.Methods in org.infinispan.remoting.inboundhandler with parameters of type DeliverOrder Modifier and Type Method Description protected void
AbstractDelegatingHandler. afterHandle(CacheRpcCommand command, DeliverOrder order, boolean delegated)
Invoked after the command is handled.protected boolean
AbstractDelegatingHandler. beforeHandle(CacheRpcCommand command, Reply reply, DeliverOrder order)
Invoked before the command is handled by the realPerCacheInboundInvocationHandler
.void
AbstractDelegatingHandler. handle(CacheRpcCommand command, Reply reply, DeliverOrder order)
void
NonTotalOrderPerCacheInboundInvocationHandler. handle(CacheRpcCommand command, Reply reply, DeliverOrder order)
void
NonTotalOrderTxPerCacheInboundInvocationHandler. handle(CacheRpcCommand command, Reply reply, DeliverOrder order)
void
PerCacheInboundInvocationHandler. handle(CacheRpcCommand command, Reply reply, DeliverOrder order)
Handles theCacheRpcCommand
from other node.void
TotalOrderTxPerCacheInboundInvocationHandler. handle(CacheRpcCommand command, Reply reply, DeliverOrder order)
void
TrianglePerCacheInboundInvocationHandler. handle(CacheRpcCommand command, Reply reply, DeliverOrder order)
void
GlobalInboundInvocationHandler. handleFromCluster(Address origin, ReplicableCommand command, Reply reply, DeliverOrder order)
void
InboundInvocationHandler. handleFromCluster(Address origin, ReplicableCommand command, Reply reply, DeliverOrder order)
Handles theReplicableCommand
from other node belonging to local site.void
GlobalInboundInvocationHandler. handleFromRemoteSite(String origin, XSiteReplicateCommand command, Reply reply, DeliverOrder order)
void
InboundInvocationHandler. handleFromRemoteSite(String origin, XSiteReplicateCommand command, Reply reply, DeliverOrder order)
Handles theReplicableCommand
from remote site. -
Uses of DeliverOrder in org.infinispan.remoting.rpc
Methods in org.infinispan.remoting.rpc that return DeliverOrder Modifier and Type Method Description DeliverOrder
RpcOptions. deliverOrder()
Methods in org.infinispan.remoting.rpc with parameters of type DeliverOrder Modifier and Type Method Description RpcOptionsBuilder
RpcOptionsBuilder. deliverMode(DeliverOrder deliverOrder)
Deprecated.RpcOptions
RpcManager. getDefaultRpcOptions(boolean sync, DeliverOrder deliverOrder)
Deprecated.Since 9.2, please useRpcManager.getSyncRpcOptions()
orRpcManager.getTotalSyncRpcOptions()
instead.RpcOptions
RpcManagerImpl. getDefaultRpcOptions(boolean sync, DeliverOrder deliverOrder)
RpcOptionsBuilder
RpcManager. getRpcOptionsBuilder(ResponseMode responseMode, DeliverOrder deliverOrder)
Deprecated.Since 9.2, please useRpcManager.getSyncRpcOptions()
instead.RpcOptionsBuilder
RpcManagerImpl. getRpcOptionsBuilder(ResponseMode responseMode, DeliverOrder deliverOrder)
void
RpcManager. sendTo(Address destination, ReplicableCommand command, DeliverOrder deliverOrder)
Asynchronously sends theReplicableCommand
to the destination using the specifiedDeliverOrder
.void
RpcManagerImpl. sendTo(Address destination, ReplicableCommand command, DeliverOrder deliverOrder)
void
RpcManager. sendToAll(ReplicableCommand command, DeliverOrder deliverOrder)
Asynchronously sends theReplicableCommand
to the entire cluster.void
RpcManagerImpl. sendToAll(ReplicableCommand command, DeliverOrder deliverOrder)
void
RpcManager. sendToMany(Collection<Address> destinations, ReplicableCommand command, DeliverOrder deliverOrder)
Asynchronously sends theReplicableCommand
to the set of destination using the specifiedDeliverOrder
.void
RpcManagerImpl. sendToMany(Collection<Address> destinations, ReplicableCommand command, DeliverOrder deliverOrder)
Constructors in org.infinispan.remoting.rpc with parameters of type DeliverOrder Constructor Description RpcOptions(long timeout, TimeUnit unit, ResponseFilter responseFilter, ResponseMode responseMode, boolean skipReplicationQueue, DeliverOrder deliverOrder)
Deprecated.Since 9.0, useRpcOptions(long, TimeUnit, ResponseFilter, ResponseMode, DeliverOrder)
instead.RpcOptions(long timeout, TimeUnit unit, ResponseFilter responseFilter, ResponseMode responseMode, DeliverOrder deliverOrder)
Deprecated.Since 9.2, useRpcOptions(DeliverOrder, long, TimeUnit)
instead.RpcOptions(DeliverOrder deliverOrder, long timeout, TimeUnit unit)
RpcOptionsBuilder(long timeout, TimeUnit unit, ResponseMode responseMode, DeliverOrder deliverOrder)
Deprecated. -
Uses of DeliverOrder in org.infinispan.remoting.transport
Methods in org.infinispan.remoting.transport with parameters of type DeliverOrder 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
.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, 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, 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)
void
AbstractDelegatingTransport. sendTo(Address destination, ReplicableCommand rpcCommand, DeliverOrder deliverOrder)
void
Transport. sendTo(Address destination, ReplicableCommand rpcCommand, DeliverOrder deliverOrder)
Asynchronously sends theReplicableCommand
to the destination using the specifiedDeliverOrder
.void
AbstractDelegatingTransport. sendToAll(ReplicableCommand rpcCommand, DeliverOrder deliverOrder)
default void
Transport. sendToAll(ReplicableCommand rpcCommand, DeliverOrder deliverOrder)
Asynchronously sends theReplicableCommand
to the entire cluster.void
AbstractDelegatingTransport. sendToMany(Collection<Address> destinations, ReplicableCommand rpcCommand, DeliverOrder deliverOrder)
void
Transport. sendToMany(Collection<Address> destinations, ReplicableCommand rpcCommand, DeliverOrder deliverOrder)
Asynchronously sends theReplicableCommand
to the set of destination using the specifiedDeliverOrder
. -
Uses of DeliverOrder in org.infinispan.remoting.transport.jgroups
Methods in org.infinispan.remoting.transport.jgroups with parameters of type DeliverOrder 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)
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)
void
JGroupsTransport. sendTo(Address destination, ReplicableCommand command, DeliverOrder deliverOrder)
void
JGroupsTransport. sendToAll(ReplicableCommand command, DeliverOrder deliverOrder)
void
JGroupsTransport. sendToMany(Collection<Address> targets, ReplicableCommand command, DeliverOrder deliverOrder)
-