Uses of Interface
org.infinispan.commands.ReplicableCommand

Packages that use ReplicableCommand

Package	Description
org.infinispan.commands	Commands that operate on the cache, either locally or remotely.
org.infinispan.commands.read
org.infinispan.commands.remote	Meta-commands that wrap other commands for remote execution.
org.infinispan.expiration.impl
org.infinispan.manager.impl
org.infinispan.marshall.exts	Externalizers for various JDK types that are marshalled using the marshalling framework.
org.infinispan.notifications.cachelistener.cluster
org.infinispan.remoting.inboundhandler.action
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.
org.infinispan.server.hotrod.command.tx
org.infinispan.topology
org.infinispan.util.concurrent.locks	Lock and synchronization related classes, tools and utilities.
org.infinispan.xsite.commands
org.infinispan.xsite.statetransfer

Uses of ReplicableCommand in org.infinispan.commands

Subinterfaces of ReplicableCommand in org.infinispan.commands

Modifier and Type	Interface	Description
interface	DataCommand	Commands of this type manipulate data in the cache.
interface	FlagAffectedCommand	Flags modify behavior of command such as whether or not to invoke certain commands remotely, check cache store etc.
interface	GlobalRpcCommand	Commands correspond to specific areas of functionality in the cluster, and can be replicated using the GlobalInboundInvocationHandler.
interface	TopologyAffectedCommand	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	VisitableCommand	A type of command that can accept Visitors, such as DDAsyncInterceptor.

Classes in org.infinispan.commands that implement ReplicableCommand

Modifier and Type	Class	Description
class	AbstractFlagAffectedCommand	Base class for those commands that can carry flags.
class	AbstractTopologyAffectedCommand	Base class for commands that carry topology id.

Methods in org.infinispan.commands that return ReplicableCommand

Modifier and Type	Method	Description
ReplicableCommand	RemoteCommandsFactory.fromStream(byte id, byte type)	Creates an un-initialized command.

Methods in org.infinispan.commands with parameters of type ReplicableCommand

Modifier and Type	Method	Description
default org.infinispan.commands.remote.SingleRpcCommand	CommandsFactory.buildSingleRpcCommand(ReplicableCommand call)	Deprecated, for removal: This API element is subject to removal in a future version. since 11.0 use CommandsFactory.buildSingleRpcCommand(VisitableCommand) instead.
static int	SegmentSpecificCommand.extractSegment(ReplicableCommand command, Object key, KeyPartitioner keyPartitioner)	Utility to extract the segment from a given command that may be a SegmentSpecificCommand.
static <K> SegmentAwareKey<K>	SegmentSpecificCommand.extractSegmentAwareKey(ReplicableCommand command, K key, KeyPartitioner keyPartitioner)	Create an SegmentAwareKey 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 use CacheRpcCommand.invokeAsync(ComponentRegistry) or GlobalRpcCommand.invokeAsync(GlobalComponentRegistry) instead.
void	CommandsFactoryImpl.initializeReplicableCommand(ReplicableCommand c, boolean isRemote)

Uses of ReplicableCommand in org.infinispan.commands.read

Classes in org.infinispan.commands.read that implement ReplicableCommand

Modifier and Type	Class	Description
class	org.infinispan.commands.read.AbstractDataCommand

Uses of ReplicableCommand in org.infinispan.commands.remote

Classes in org.infinispan.commands.remote that implement ReplicableCommand

Modifier and Type	Class	Description
class	org.infinispan.commands.remote.BaseRpcCommand

Uses of ReplicableCommand in org.infinispan.expiration.impl

Classes in org.infinispan.expiration.impl that implement ReplicableCommand

Modifier and Type	Class	Description
class	TouchCommand	This command updates a cache entry's last access timestamp.

Uses of ReplicableCommand in org.infinispan.manager.impl

Classes in org.infinispan.manager.impl that implement ReplicableCommand

Modifier and Type	Class	Description
class	ReplicableManagerFunctionCommand	Replicable Command that runs the given Function passing the EmbeddedCacheManager as an argument
class	ReplicableRunnableCommand	Replicable Command that runs the given Runnable

Uses of ReplicableCommand in org.infinispan.marshall.exts

Methods in org.infinispan.marshall.exts that return ReplicableCommand

Modifier and Type	Method	Description
ReplicableCommand	ReplicableCommandExternalizer.readObject(ObjectInput input)

Methods in org.infinispan.marshall.exts that return types with arguments of type ReplicableCommand

Modifier and Type	Method	Description
Set<Class<? extends ReplicableCommand>>	ReplicableCommandExternalizer.getTypeClasses()

Methods in org.infinispan.marshall.exts with parameters of type ReplicableCommand

Modifier and Type	Method	Description
protected 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

Classes in org.infinispan.notifications.cachelistener.cluster that implement ReplicableCommand

Modifier and Type	Class	Description
class	MultiClusterEventCommand<K,V>	This command is used to send cluster events for multiple listeners on the same node

Uses of ReplicableCommand in org.infinispan.remoting.inboundhandler.action

Methods in org.infinispan.remoting.inboundhandler.action with type parameters of type ReplicableCommand

Modifier and Type	Method	Description
final <T extends ReplicableCommand> T	ActionState.getCommand()

Constructors in org.infinispan.remoting.inboundhandler.action with parameters of type ReplicableCommand

Modifier	Constructor	Description
	ActionState(ReplicableCommand command, int commandTopologyId)

Uses of ReplicableCommand in org.infinispan.remoting.rpc

Methods in org.infinispan.remoting.rpc with parameters of type ReplicableCommand

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 a ResponseCollector.
<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 a ResponseCollector.
<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 a ResponseCollector.
<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 a ResponseCollector.
<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. since 11.0, use RpcManager.sendToMany(Collection, ReplicableCommand, DeliverOrder) or RpcManager.invokeCommand(Collection, ReplicableCommand, ResponseCollector, RpcOptions) instead.
CompletableFuture<Map<Address,Response>>	RpcManagerImpl.invokeRemotelyAsync(Collection<Address> recipients, ReplicableCommand rpc, RpcOptions options)
void	RpcManager.sendTo(Address destination, ReplicableCommand command, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder)	Asynchronously sends the ReplicableCommand to the destination using the specified DeliverOrder.
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 the ReplicableCommand 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 the ReplicableCommand to the set of destination using the specified DeliverOrder.
void	RpcManagerImpl.sendToMany(Collection<Address> destinations, ReplicableCommand command, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder)

Method parameters in org.infinispan.remoting.rpc with type arguments of type ReplicableCommand

Modifier and Type	Method	Description
<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 a ResponseCollector.
<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

Methods in org.infinispan.remoting.transport with parameters of type ReplicableCommand

Modifier and Type	Method	Description
<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 a ResponseCollector.
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 a ResponseCollector.
<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 a ResponseCollector.
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 a ResponseCollector.
<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 a ResponseCollector.
CompletableFuture<Map<Address,Response>>	AbstractDelegatingTransport.invokeRemotelyAsync(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, ResponseFilter responseFilter, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, boolean anycast)
CompletableFuture<Map<Address,Response>>	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 the ReplicableCommand to the destination using the specified DeliverOrder.
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 the ReplicableCommand 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 the ReplicableCommand to the set of destination using the specified DeliverOrder.

Method parameters in org.infinispan.remoting.transport with type arguments of type ReplicableCommand

Modifier and Type	Method	Description
<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 with Transport.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 a ResponseCollector.
Map<Address,Response>	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.
Map<Address,Response>	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.
default Map<Address,Response>	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. Use Transport.invokeRemotely(Map, ResponseMode, long, ResponseFilter, DeliverOrder, boolean) instead
default Map<Address,Response>	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 use Transport.invokeRemotelyAsync(Collection, ReplicableCommand, ResponseMode, long, ResponseFilter, DeliverOrder, boolean) instead.

Uses of ReplicableCommand in org.infinispan.remoting.transport.jgroups

Methods in org.infinispan.remoting.transport.jgroups with parameters of type ReplicableCommand

Modifier and Type	Method	Description
<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)
CompletableFuture<Map<Address,Response>>	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)

Method parameters in org.infinispan.remoting.transport.jgroups with type arguments of type ReplicableCommand

Modifier and Type	Method	Description
<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)
Map<Address,Response>	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

Classes in org.infinispan.server.hotrod.command.tx that implement ReplicableCommand

Modifier and Type	Class	Description
class	ForwardCommitCommand	A CacheRpcCommand implementation to forward the commit request from a client to the member that run the transaction.
class	ForwardRollbackCommand	A CacheRpcCommand implementation to forward the rollback request from a client to the member that run the transaction.

Uses of ReplicableCommand in org.infinispan.topology

Classes in org.infinispan.topology that implement ReplicableCommand

Modifier and Type	Class	Description
class	HeartBeatCommand	A hear-beat command used to ping members in ClusterTopologyManagerImpl.confirmMembersAvailable().

Methods in org.infinispan.topology with parameters of type ReplicableCommand

Modifier and Type	Method	Description
void	TopologyManagementHelper.executeOnClusterAsync(Transport transport, ReplicableCommand command)
<T> CompletionStage<T>	TopologyManagementHelper.executeOnClusterSync(Transport transport, ReplicableCommand command, int timeout, ResponseCollector<T> responseCollector)
CompletionStage<Object>	TopologyManagementHelper.executeOnCoordinator(Transport transport, ReplicableCommand command, long timeoutMillis)
CompletionStage<Object>	LocalTopologyManagerImpl.executeOnCoordinatorRetry(ReplicableCommand command, int viewId, long endNanos)

Uses of ReplicableCommand in org.infinispan.util.concurrent.locks

Subinterfaces of ReplicableCommand in org.infinispan.util.concurrent.locks

Modifier and Type	Interface	Description
interface	RemoteLockCommand	Simple interface to extract all the keys that may need to be locked.
interface	TransactionalRemoteLockCommand	Simple interface to extract all the keys that may need to be locked for transactional commands.

Uses of ReplicableCommand in org.infinispan.xsite.commands

Classes in org.infinispan.xsite.commands that implement ReplicableCommand

Modifier and Type	Class	Description
class	XSiteAmendOfflineStatusCommand	Amend a sites offline status.
class	XSiteAutoTransferStatusCommand	A CacheRpcCommand to check the remote site status and state transfer mode in the local cluster.
class	XSiteBringOnlineCommand	Take a site offline.
class	XSiteLocalEventCommand	Sends XSiteEvent list from a local site node.
class	XSiteOfflineStatusCommand	Get the offline status of a BackupSender.
class	XSiteSetStateTransferModeCommand	A CacheRpcCommand that sets the XSiteStateTransferMode cluster-wide.
class	XSiteStateTransferCancelSendCommand	Cancel sending XSite state.
class	XSiteStateTransferClearStatusCommand	Clear XSite state transfer status.
class	XSiteStateTransferFinishReceiveCommand	Finish receiving XSite state.
class	XSiteStateTransferFinishSendCommand	Finish sending XSite state.
class	XSiteStateTransferRestartSendingCommand	Restart sending XSite state.
class	XSiteStateTransferStartReceiveCommand	Start receiving XSite state.
class	XSiteStateTransferStartSendCommand	Start send XSite state.
class	XSiteStateTransferStatusRequestCommand	Get XSite state transfer status.
class	XSiteStatusCommand	Return the status of a BackupSender.
class	XSiteTakeOfflineCommand	Take a site offline.

Uses of ReplicableCommand in org.infinispan.xsite.statetransfer

Classes in org.infinispan.xsite.statetransfer that implement ReplicableCommand

Modifier and Type	Class	Description
class	XSiteStatePushCommand	Wraps the state to be sent to another site