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.notifications.cachelistener.cluster
org.infinispan.remoting.inboundhandler.action
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. a 'get' command cannot execute on a node that is no longer owner after state transfer took place).
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 with parameters of type ReplicableCommand

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

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

Subinterfaces of ReplicableCommand in org.infinispan.commands.remote

Modifier and Type	Interface	Description
interface	org.infinispan.commands.remote.CacheRpcCommand	The RpcManager only replicates commands wrapped in a CacheRpcCommand.

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.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.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<Address,T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit)
<T> CompletionStage<T>	AbstractDelegatingTransport.invokeCommand(Address target, ReplicableCommand command, ResponseCollector<Address,T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit)
default <T> CompletionStage<T>	Transport.invokeCommand(Collection<Address> targets, ReplicableCommand command, ResponseCollector<Address,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<Address,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<Address,T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit)
default <T> CompletionStage<T>	Transport.invokeCommandOnAll(Collection<Address> requiredTargets, ReplicableCommand command, ResponseCollector<Address,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<Address,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<Address,T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit)
default <T> CompletionStage<T>	Transport.invokeCommandStaggered(Collection<Address> targets, ReplicableCommand command, ResponseCollector<Address,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)
CompletableFuture<Map<Address,Response>>	Transport.invokeRemotelyAsync(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, ResponseFilter responseFilter, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder)
default 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)	Deprecated, for removal: This API element is subject to removal in a future version. Use Transport.invokeRemotelyAsync(Collection, ReplicableCommand, ResponseMode, long, ResponseFilter, DeliverOrder).
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<Address,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<Address,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.

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<Address,T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit)
<T> CompletionStage<T>	JGroupsTransport.invokeCommand(Address target, ReplicableCommand command, ResponseCollector<Address,T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit)
<T> CompletionStage<T>	JGroupsTransport.invokeCommandOnAll(Collection<Address> requiredTargets, ReplicableCommand command, ResponseCollector<Address,T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit)
<T> CompletionStage<T>	JGroupsTransport.invokeCommandOnAll(ReplicableCommand command, ResponseCollector<Address,T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit)
<T> CompletionStage<T>	JGroupsTransport.invokeCommandStaggered(Collection<Address> targets, ReplicableCommand command, ResponseCollector<Address,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)
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<Address,T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit timeUnit)

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<Address,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	XSiteLocalEventCommand	Sends XSiteEvent list from a local site node.
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.

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