Uses of Interface
org.infinispan.commands.ReplicableCommand
Package
Description
Commands that operate on the cache, either locally or remotely.
Meta-commands that wrap other commands for remote execution.
Externalizers for various JDK types that are marshalled using the marshalling framework.
Remote Procedure Call (RPC) interfaces and components used to invoke remote methods on cache instances.
Transports handle the low-level networking, used by the remoting components.
A transport implementation based on JGroups.
General utilities that are not specific to Infinispan, including string parsing helpers, reflection tools and
collections and containers designed to supplement the JDK-provided containers.
Lock and synchronization related classes, tools and utilities.
-
Uses of ReplicableCommand in org.infinispan.commands
Modifier and TypeInterfaceDescriptioninterface
Commands of this type manipulate data in the cache.interface
Flags modify behavior of command such as whether or not to invoke certain commands remotely, check cache store etc.interface
Commands correspond to specific areas of functionality in the cluster, and can be replicated using theGlobalInboundInvocationHandler
.interface
Some of the commands sent over the wire can only be honored by the receiver if the topology of the cluster at delivery time is still 'compatible' with the topology in place at send time (eg.interface
A type of command that can acceptVisitor
s, such asDDAsyncInterceptor
.Modifier and TypeClassDescriptionclass
Base class for those commands that can carry flags.class
Base class for commands that carry topology id.Modifier and TypeMethodDescriptionRemoteCommandsFactory.fromStream
(byte id, byte type) Creates an un-initialized command.Modifier and TypeMethodDescriptiondefault org.infinispan.commands.remote.SingleRpcCommand
CommandsFactory.buildSingleRpcCommand
(ReplicableCommand call) Deprecated, for removal: This API element is subject to removal in a future version.static int
SegmentSpecificCommand.extractSegment
(ReplicableCommand command, Object key, KeyPartitioner keyPartitioner) Utility to extract the segment from a given command that may be aSegmentSpecificCommand
.static <K> SegmentAwareKey<K>
SegmentSpecificCommand.extractSegmentAwareKey
(ReplicableCommand command, K key, KeyPartitioner keyPartitioner) Create anSegmentAwareKey
instance with the key and its segment.void
CommandsFactory.initializeReplicableCommand
(ReplicableCommand command, boolean isRemote) Deprecated, for removal: This API element is subject to removal in a future version.since 11.0, please useCacheRpcCommand.invokeAsync(ComponentRegistry)
orGlobalRpcCommand.invokeAsync(GlobalComponentRegistry)
instead.void
CommandsFactoryImpl.initializeReplicableCommand
(ReplicableCommand c, boolean isRemote) -
Uses of ReplicableCommand in org.infinispan.commands.read
Modifier and TypeClassDescriptionclass
org.infinispan.commands.read.AbstractDataCommand
-
Uses of ReplicableCommand in org.infinispan.commands.remote
Modifier and TypeClassDescriptionclass
org.infinispan.commands.remote.BaseRpcCommand
-
Uses of ReplicableCommand in org.infinispan.expiration.impl
Modifier and TypeClassDescriptionclass
This command updates a cache entry's last access timestamp. -
Uses of ReplicableCommand in org.infinispan.extendedstats.wrappers
Modifier and TypeMethodDescription<T> CompletionStage<T>
ExtendedStatisticRpcManager.invokeCommand
(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions) <T> CompletionStage<T>
ExtendedStatisticRpcManager.invokeCommand
(Address target, ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions) <T> CompletionStage<T>
ExtendedStatisticRpcManager.invokeCommandOnAll
(ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions) <T> CompletionStage<T>
ExtendedStatisticRpcManager.invokeCommandStaggered
(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions) ExtendedStatisticRpcManager.invokeRemotelyAsync
(Collection<Address> recipients, ReplicableCommand rpc, RpcOptions options) void
ExtendedStatisticRpcManager.sendTo
(Address destination, ReplicableCommand command, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder) void
ExtendedStatisticRpcManager.sendToAll
(ReplicableCommand command, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder) void
ExtendedStatisticRpcManager.sendToMany
(Collection<Address> destinations, ReplicableCommand command, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder) Modifier and TypeMethodDescription<T> CompletionStage<T>
ExtendedStatisticRpcManager.invokeCommands
(Collection<Address> targets, Function<Address, ReplicableCommand> commandGenerator, ResponseCollector<T> collector, RpcOptions rpcOptions) -
Uses of ReplicableCommand in org.infinispan.manager.impl
Modifier and TypeClassDescriptionclass
Replicable Command that runs the given Function passing theEmbeddedCacheManager
as an argumentclass
Replicable Command that runs the given Runnable -
Uses of ReplicableCommand in org.infinispan.marshall.exts
Modifier and TypeMethodDescriptionSet<Class<? extends ReplicableCommand>>
ReplicableCommandExternalizer.getTypeClasses()
Modifier and TypeMethodDescriptionprotected void
ReplicableCommandExternalizer.writeCommandHeader
(ObjectOutput output, ReplicableCommand command) protected void
ReplicableCommandExternalizer.writeCommandParameters
(ObjectOutput output, ReplicableCommand command) void
ReplicableCommandExternalizer.writeObject
(ObjectOutput output, ReplicableCommand command) -
Uses of ReplicableCommand in org.infinispan.notifications.cachelistener.cluster
Modifier and TypeClassDescriptionclass
This command is used to send cluster events for multiple listeners on the same node -
Uses of ReplicableCommand in org.infinispan.remoting.inboundhandler.action
-
Uses of ReplicableCommand in org.infinispan.remoting.rpc
Modifier and TypeMethodDescription<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.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) default CompletableFuture<Map<Address,
Response>> RpcManager.invokeRemotelyAsync
(Collection<Address> recipients, ReplicableCommand rpc, RpcOptions options) Deprecated, for removal: This API element is subject to removal in a future version.RpcManagerImpl.invokeRemotelyAsync
(Collection<Address> recipients, ReplicableCommand rpc, RpcOptions options) void
RpcManager.sendTo
(Address destination, ReplicableCommand command, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder) Asynchronously sends theReplicableCommand
to the destination using the specifiedDeliverOrder
.void
RpcManagerImpl.sendTo
(Address destination, ReplicableCommand command, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder) void
RpcManager.sendToAll
(ReplicableCommand command, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder) Asynchronously sends theReplicableCommand
to the entire cluster.void
RpcManagerImpl.sendToAll
(ReplicableCommand command, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder) void
RpcManager.sendToMany
(Collection<Address> destinations, ReplicableCommand command, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder) Asynchronously sends theReplicableCommand
to the set of destination using the specifiedDeliverOrder
.void
RpcManagerImpl.sendToMany
(Collection<Address> destinations, ReplicableCommand command, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder) Modifier and TypeMethodDescription<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) -
Uses of ReplicableCommand in org.infinispan.remoting.transport
Modifier and TypeMethodDescription<T> CompletionStage<T>
AbstractDelegatingTransport.invokeCommand
(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit) <T> CompletionStage<T>
AbstractDelegatingTransport.invokeCommand
(Address target, ReplicableCommand command, ResponseCollector<T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit) default <T> CompletionStage<T>
Transport.invokeCommand
(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, org.infinispan.remoting.inboundhandler.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, org.infinispan.remoting.inboundhandler.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, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit) default <T> CompletionStage<T>
Transport.invokeCommandOnAll
(Collection<Address> requiredTargets, ReplicableCommand command, ResponseCollector<T> collector, org.infinispan.remoting.inboundhandler.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, org.infinispan.remoting.inboundhandler.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.invokeCommandStaggered
(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit) default <T> CompletionStage<T>
Transport.invokeCommandStaggered
(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit) Invoke a command on a collection of nodes and pass the responses to aResponseCollector
.AbstractDelegatingTransport.invokeRemotely
(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, ResponseFilter responseFilter, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, boolean anycast) Deprecated, for removal: This API element is subject to removal in a future version.Transport.invokeRemotely
(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, ResponseFilter responseFilter, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, boolean anycast) Deprecated, for removal: This API element is subject to removal in a future version.Since 9.2, please useTransport.invokeCommand(Collection, ReplicableCommand, ResponseCollector, DeliverOrder, long, TimeUnit)
instead.AbstractDelegatingTransport.invokeRemotelyAsync
(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, ResponseFilter responseFilter, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, boolean anycast) Transport.invokeRemotelyAsync
(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, ResponseFilter responseFilter, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, boolean anycast) void
AbstractDelegatingTransport.sendTo
(Address destination, ReplicableCommand rpcCommand, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder) void
Transport.sendTo
(Address destination, ReplicableCommand rpcCommand, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder) Asynchronously sends theReplicableCommand
to the destination using the specifiedDeliverOrder
.void
AbstractDelegatingTransport.sendToAll
(ReplicableCommand rpcCommand, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder) default void
Transport.sendToAll
(ReplicableCommand rpcCommand, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder) Asynchronously sends theReplicableCommand
to the entire cluster.void
AbstractDelegatingTransport.sendToMany
(Collection<Address> destinations, ReplicableCommand rpcCommand, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder) void
Transport.sendToMany
(Collection<Address> destinations, ReplicableCommand rpcCommand, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder) Asynchronously sends theReplicableCommand
to the set of destination using the specifiedDeliverOrder
.Modifier and TypeMethodDescription<T> CompletionStage<T>
AbstractDelegatingTransport.invokeCommands
(Collection<Address> targets, Function<Address, ReplicableCommand> commandGenerator, ResponseCollector<T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit timeUnit) default <T> CompletionStage<T>
Transport.invokeCommands
(Collection<Address> targets, Function<Address, ReplicableCommand> commandGenerator, ResponseCollector<T> responseCollector, long timeout, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder) Deprecated, for removal: This API element is subject to removal in a future version.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, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit timeUnit) Invoke different commands on a collection of nodes and pass the responses to aResponseCollector
.AbstractDelegatingTransport.invokeRemotely
(Map<Address, ReplicableCommand> rpcCommands, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter, boolean totalOrder, boolean anycast) Deprecated, for removal: This API element is subject to removal in a future version.AbstractDelegatingTransport.invokeRemotely
(Map<Address, ReplicableCommand> rpcCommands, ResponseMode mode, long timeout, ResponseFilter responseFilter, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, boolean anycast) Deprecated, for removal: This API element is subject to removal in a future version.Transport.invokeRemotely
(Map<Address, ReplicableCommand> rpcCommands, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter, boolean totalOrder, boolean anycast) Deprecated, for removal: This API element is subject to removal in a future version.Transport.invokeRemotely
(Map<Address, ReplicableCommand> rpcCommands, ResponseMode mode, long timeout, ResponseFilter responseFilter, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, boolean anycast) Deprecated, for removal: This API element is subject to removal in a future version.Since 9.2, please useTransport.invokeRemotelyAsync(Collection, ReplicableCommand, ResponseMode, long, ResponseFilter, DeliverOrder, boolean)
instead. -
Uses of ReplicableCommand in org.infinispan.remoting.transport.jgroups
Modifier and TypeMethodDescription<T> CompletionStage<T>
JGroupsTransport.invokeCommand
(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit) <T> CompletionStage<T>
JGroupsTransport.invokeCommand
(Address target, ReplicableCommand command, ResponseCollector<T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit) <T> CompletionStage<T>
JGroupsTransport.invokeCommandOnAll
(Collection<Address> requiredTargets, ReplicableCommand command, ResponseCollector<T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit) <T> CompletionStage<T>
JGroupsTransport.invokeCommandOnAll
(ReplicableCommand command, ResponseCollector<T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit) <T> CompletionStage<T>
JGroupsTransport.invokeCommandStaggered
(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit) JGroupsTransport.invokeRemotelyAsync
(Collection<Address> recipients, ReplicableCommand command, ResponseMode mode, long timeout, ResponseFilter responseFilter, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, boolean anycast) void
JGroupsTransport.sendTo
(Address destination, ReplicableCommand command, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder) void
JGroupsTransport.sendToAll
(ReplicableCommand command, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder) void
JGroupsTransport.sendToMany
(Collection<Address> targets, ReplicableCommand command, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder) Modifier and TypeMethodDescription<T> CompletionStage<T>
JGroupsTransport.invokeCommands
(Collection<Address> targets, Function<Address, ReplicableCommand> commandGenerator, ResponseCollector<T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit timeUnit) JGroupsTransport.invokeRemotely
(Map<Address, ReplicableCommand> commands, ResponseMode mode, long timeout, ResponseFilter responseFilter, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, boolean anycast) Deprecated, for removal: This API element is subject to removal in a future version. -
Uses of ReplicableCommand in org.infinispan.server.hotrod.command.tx
Modifier and TypeClassDescriptionclass
ACacheRpcCommand
implementation to forward the commit request from a client to the member that run the transaction.class
ACacheRpcCommand
implementation to forward the rollback request from a client to the member that run the transaction. -
Uses of ReplicableCommand in org.infinispan.topology
Modifier and TypeClassDescriptionclass
A hear-beat command used to ping members inClusterTopologyManagerImpl.confirmMembersAvailable()
.Modifier and TypeMethodDescriptionvoid
TopologyManagementHelper.executeOnClusterAsync
(Transport transport, ReplicableCommand command) <T> CompletionStage<T>
TopologyManagementHelper.executeOnClusterSync
(Transport transport, ReplicableCommand command, int timeout, ResponseCollector<T> responseCollector) TopologyManagementHelper.executeOnCoordinator
(Transport transport, ReplicableCommand command, long timeoutMillis) LocalTopologyManagerImpl.executeOnCoordinatorRetry
(ReplicableCommand command, int viewId, long endNanos) -
Uses of ReplicableCommand in org.infinispan.util
Modifier and TypeMethodDescriptionCollection<Class<? extends ReplicableCommand>>
ModuleProperties.moduleCommands()
Deprecated, for removal: This API element is subject to removal in a future version.Collection<Class<? extends ReplicableCommand>>
ModuleProperties.moduleOnlyReplicableCommands()
Deprecated, for removal: This API element is subject to removal in a future version. -
Uses of ReplicableCommand in org.infinispan.util.concurrent.locks
Modifier and TypeInterfaceDescriptioninterface
Simple interface to extract all the keys that may need to be locked.interface
Simple interface to extract all the keys that may need to be locked for transactional commands. -
Uses of ReplicableCommand in org.infinispan.xsite.commands
Modifier and TypeClassDescriptionclass
Amend a sites offline status.class
ACacheRpcCommand
to check the remote site status and state transfer mode in the local cluster.class
Take a site offline.class
SendsXSiteEvent
list from a local site node.class
Get the offline status of aBackupSender
.class
ACacheRpcCommand
that sets theXSiteStateTransferMode
cluster-wide.class
Cancel sending XSite state.class
Clear XSite state transfer status.class
Finish receiving XSite state.class
Finish sending XSite state.class
Restart sending XSite state.class
Start receiving XSite state.class
Start send XSite state.class
Get XSite state transfer status.class
Return the status of aBackupSender
.class
Take a site offline. -
Uses of ReplicableCommand in org.infinispan.xsite.statetransfer
Modifier and TypeClassDescriptionclass
Wraps the state to be sent to another site
CommandsFactory.buildSingleRpcCommand(VisitableCommand)
instead.