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.control
org.infinispan.commands.module
org.infinispan.commands.read
org.infinispan.commands.remote	Meta-commands that wrap other commands for remote execution.
org.infinispan.commands.remote.recovery
org.infinispan.commands.tx	Commands that represent transactional lifecycle transitions.
org.infinispan.commands.write	Commands that alter the state of the cache.
org.infinispan.marshall.exts	Externalizers for various JDK types that are marshalled using the marshalling framework.
org.infinispan.query
org.infinispan.query.clustered
org.infinispan.query.indexmanager
org.infinispan.remoting	Remote communication between cache instances.
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.statetransfer	Transfer of state to new caches in a cluster.
org.infinispan.topology
org.infinispan.util	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.
org.infinispan.util.logging	Infinispan's logging abstractions that delegate to either JDK or Log4J logging engines.
org.infinispan.xsite

Uses of ReplicableCommand in org.infinispan.commands

Subinterfaces of ReplicableCommand in org.infinispan.commands

Modifier and Type	Interface and Description
interface	CancellableCommand CancellableCommand is a command whose execution in remote VM can be canceled (if needed)
interface	DataCommand Commands of this type manipulate data in the cache.
interface	FlagAffectedCommand Commands affected by Flags should carry them over to the remote nodes.
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 CommandInterceptors.

Classes in org.infinispan.commands that implement ReplicableCommand

Modifier and Type	Class and Description
class	AbstractFlagAffectedCommand Base class for those commands that can carry flags.
class	CancelCommand Command to cancel commands executing in remote VM
class	CreateCacheCommand Command to create/start a cache on a subset of Infinispan cluster nodes
class	RemoveCacheCommand Command to stop a cache and remove all its contents from both memory and any backing store.

Methods in org.infinispan.commands that return ReplicableCommand

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

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

Modifier and Type	Method and Description
SingleRpcCommand	CommandsFactoryImpl.buildSingleRpcCommand(ReplicableCommand call)
SingleRpcCommand	CommandsFactory.buildSingleRpcCommand(ReplicableCommand call) Builds a SingleRpcCommand "envelope" containing a single ReplicableCommand
void	CommandsFactoryImpl.initializeReplicableCommand(ReplicableCommand c, boolean isRemote)
void	CommandsFactory.initializeReplicableCommand(ReplicableCommand command, boolean isRemote) Initializes a ReplicableCommand read from a data stream with components specific to the target cache instance.

Method parameters in org.infinispan.commands with type arguments of type ReplicableCommand

Modifier and Type	Method and Description
MultipleRpcCommand	CommandsFactoryImpl.buildReplicateCommand(List<ReplicableCommand> toReplicate)
MultipleRpcCommand	CommandsFactory.buildReplicateCommand(List<ReplicableCommand> toReplicate) Builds an RpcCommand "envelope" containing multiple ReplicableCommands

Uses of ReplicableCommand in org.infinispan.commands.control

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

Modifier and Type	Class and Description
class	LockControlCommand LockControlCommand is a command that enables distributed locking across infinispan nodes.

Uses of ReplicableCommand in org.infinispan.commands.module

Methods in org.infinispan.commands.module that return ReplicableCommand

Modifier and Type	Method and Description
ReplicableCommand	ModuleCommandFactory.fromStream(byte commandId, Object[] args) Construct and initialize a ReplicableCommand based on the command id and argument array passed in.

Methods in org.infinispan.commands.module that return types with arguments of type ReplicableCommand

Modifier and Type	Method and Description
Map<Byte,Class<? extends ReplicableCommand>>	ModuleCommandFactory.getModuleCommands() Provides a map of command IDs to command types of all the commands handled by the command factory instance.

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

Modifier and Type	Method and Description
void	ModuleCommandInitializer.initializeReplicableCommand(ReplicableCommand c, boolean isRemote) Initializes a command constructed using ModuleCommandFactory.fromStream(byte, Object[]) with necessary named-cache-specific components.

Uses of ReplicableCommand in org.infinispan.commands.read

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

Modifier and Type	Class and Description
class	AbstractDataCommand
class	DistributedExecuteCommand<V> DistributedExecuteCommand is used to migrate Callable and execute it in remote JVM.
class	EntrySetCommand Command implementation for Map.entrySet() functionality.
class	GetCacheEntryCommand An internal cache get command that returns CacheEntry instead of just the value.
class	GetKeyValueCommand Implements functionality defined by Map.get(Object) and Map.containsKey(Object) operations
class	KeySetCommand Command implementation for Map.keySet() functionality.
class	MapCombineCommand<KIn,VIn,KOut,VOut> MapCombineCommand is a container to migrate Mapper and Reducer which is a combiner to a remote Infinispan node where it will get executed and return the result to an invoking/master node.
class	ReduceCommand<KOut,VOut> ReduceCommand is a container to migrate Reducer to a remote Infinispan node where it will get executed and return the result to an invoking/master node.
class	SizeCommand Command to calculate the size of the cache
class	ValuesCommand Command implementation for Map.values() functionality.

Uses of ReplicableCommand in org.infinispan.commands.remote

Subinterfaces of ReplicableCommand in org.infinispan.commands.remote

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

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

Modifier and Type	Class and Description
class	BaseRpcCommand
class	BaseRpcInvokingCommand Base class for RPC commands.
class	ClusteredGetCommand Issues a remote get call.
class	MultipleRpcCommand Command that implements cluster replication logic.
class	SingleRpcCommand Similar to MultipleRpcCommand, but it only aggregates a single command for replication.

Methods in org.infinispan.commands.remote that return ReplicableCommand

Modifier and Type	Method and Description
ReplicableCommand	SingleRpcCommand.getCommand()
ReplicableCommand[]	MultipleRpcCommand.getCommands()

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

Modifier and Type	Method and Description
protected Object	BaseRpcInvokingCommand.processVisitableCommand(ReplicableCommand cacheCommand)

Constructors in org.infinispan.commands.remote with parameters of type ReplicableCommand

Constructor and Description
SingleRpcCommand(String cacheName, ReplicableCommand command)

Constructor parameters in org.infinispan.commands.remote with type arguments of type ReplicableCommand

Constructor and Description
MultipleRpcCommand(List<ReplicableCommand> modifications, String cacheName)

Uses of ReplicableCommand in org.infinispan.commands.remote.recovery

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

Modifier and Type	Class and Description
class	CompleteTransactionCommand Command used by the recovery tooling for forcing transaction completion .
class	GetInDoubtTransactionsCommand Rpc to obtain all in-doubt prepared transactions stored on remote nodes.
class	GetInDoubtTxInfoCommand Command used by the recovery tooling for obtaining the list of in-doubt transactions from a node.
class	RecoveryCommand Base class for recovery-related rpc-commands.
class	TxCompletionNotificationCommand Command for removing recovery related information from the cluster.

Uses of ReplicableCommand in org.infinispan.commands.tx

Subinterfaces of ReplicableCommand in org.infinispan.commands.tx

Modifier and Type	Interface and Description
interface	TransactionBoundaryCommand An transaction boundary command that allows the retrieval of an attached GlobalTransaction

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

Modifier and Type	Class and Description
class	AbstractTransactionBoundaryCommand An abstract transaction boundary command that holds a reference to a GlobalTransaction
class	CommitCommand Command corresponding to the 2nd phase of 2PC.
class	PrepareCommand Command corresponding to the 1st phase of 2PC.
class	RollbackCommand Command corresponding to a transaction rollback.
class	VersionedCommitCommand The same as a CommitCommand except that version information is also carried by this command, used by optimistically transactional caches making use of write skew checking when using IsolationLevel.REPEATABLE_READ.
class	VersionedPrepareCommand Same as PrepareCommand except that the transaction originator makes evident the versions of entries touched and stored in a transaction context so that accurate write skew checks may be performed by the lock owner(s).

Uses of ReplicableCommand in org.infinispan.commands.write

Subinterfaces of ReplicableCommand in org.infinispan.commands.write

Modifier and Type	Interface and Description
interface	DataWriteCommand Mixes features from DataCommand and WriteCommand
interface	WriteCommand A command that modifies the cache in some way

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

Modifier and Type	Class and Description
class	AbstractDataWriteCommand Stuff common to WriteCommands
class	ApplyDeltaCommand
class	ClearCommand
class	EvictCommand
class	InvalidateCommand Removes an entry from memory.
class	InvalidateL1Command Invalidates an entry in a L1 cache (used with DIST mode)
class	PutKeyValueCommand Implements functionality defined by BasicCache.put(Object, Object)
class	PutMapCommand
class	RemoveCommand
class	ReplaceCommand
class	VersionedPutKeyValueCommand A form of PutKeyValueCommand that also applies a version to the entry created.

Uses of ReplicableCommand in org.infinispan.marshall.exts

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

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

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

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

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

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

Methods in org.infinispan.query that return ReplicableCommand

Modifier and Type	Method and Description
ReplicableCommand	CommandFactory.fromStream(byte commandId, Object[] args)

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

Modifier and Type	Method and Description
Map<Byte,Class<? extends ReplicableCommand>>	CommandFactory.getModuleCommands()

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

Modifier and Type	Method and Description
void	CommandInitializer.initializeReplicableCommand(ReplicableCommand c, boolean isRemote)

Uses of ReplicableCommand in org.infinispan.query.clustered

Classes in org.infinispan.query.clustered that implement ReplicableCommand

Modifier and Type	Class and Description
class	ClusteredQueryCommand Encapsulates all rpc calls for distributed queries actions

Uses of ReplicableCommand in org.infinispan.query.indexmanager

Classes in org.infinispan.query.indexmanager that implement ReplicableCommand

Modifier and Type	Class and Description
class	IndexUpdateCommand Custom RPC command containing an index update request for the Master IndexManager of a specific cache & index.

Uses of ReplicableCommand in org.infinispan.remoting

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

Modifier and Type	Method and Description
protected List<ReplicableCommand>	ReplicationQueueImpl.drainReplQueue()

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

Modifier and Type	Method and Description
void	ReplicationQueueImpl.add(ReplicableCommand job)
void	ReplicationQueue.add(ReplicableCommand job) Adds a new command to the replication queue.

Uses of ReplicableCommand in org.infinispan.remoting.rpc

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

Modifier and Type	Method and Description
void	RpcManagerImpl.broadcastRpcCommand(ReplicableCommand rpc, boolean sync)
void	RpcManager.broadcastRpcCommand(ReplicableCommand rpc, boolean sync) Broadcasts an RPC command to the entire cluster.
void	RpcManagerImpl.broadcastRpcCommand(ReplicableCommand rpc, boolean sync, boolean usePriorityQueue)
void	RpcManager.broadcastRpcCommand(ReplicableCommand rpc, boolean sync, boolean usePriorityQueue) Broadcasts an RPC command to the entire cluster.
void	RpcManagerImpl.broadcastRpcCommandInFuture(ReplicableCommand rpc, boolean usePriorityQueue, NotifyingNotifiableFuture<Object> l)
void	RpcManager.broadcastRpcCommandInFuture(ReplicableCommand rpc, boolean usePriorityQueue, NotifyingNotifiableFuture<Object> future) The same as RpcManager.broadcastRpcCommand(org.infinispan.commands.ReplicableCommand, boolean, boolean) except that the task is passed to the transport executor and a Future is returned.
void	RpcManagerImpl.broadcastRpcCommandInFuture(ReplicableCommand rpc, NotifyingNotifiableFuture<Object> l)
void	RpcManager.broadcastRpcCommandInFuture(ReplicableCommand rpc, NotifyingNotifiableFuture<Object> future) The same as RpcManager.broadcastRpcCommand(org.infinispan.commands.ReplicableCommand, boolean) except that the task is passed to the transport executor and a Future is returned.
Map<Address,Response>	RpcManagerImpl.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, boolean sync)
Map<Address,Response>	RpcManager.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, boolean sync) Broadcasts an RPC command to a specified set of recipients
Map<Address,Response>	RpcManagerImpl.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, boolean sync, boolean usePriorityQueue)
Map<Address,Response>	RpcManager.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, boolean sync, boolean usePriorityQueue) Broadcasts an RPC command to a specified set of recipients
Map<Address,Response>	RpcManagerImpl.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, boolean sync, boolean usePriorityQueue, long timeout)
Map<Address,Response>	RpcManagerImpl.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout)
Map<Address,Response>	RpcManager.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout) Invokes an RPC call on other caches in the cluster.
Map<Address,Response>	RpcManagerImpl.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue)
Map<Address,Response>	RpcManager.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue) Invokes an RPC call on other caches in the cluster.
Map<Address,Response>	RpcManagerImpl.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter)
Map<Address,Response>	RpcManager.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter) Invokes an RPC call on other caches in the cluster.
void	RpcManagerImpl.invokeRemotelyInFuture(Collection<Address> recipients, ReplicableCommand rpc, boolean usePriorityQueue, NotifyingNotifiableFuture<Object> l)
void	RpcManager.invokeRemotelyInFuture(Collection<Address> recipients, ReplicableCommand rpc, boolean usePriorityQueue, NotifyingNotifiableFuture<Object> future) The same as RpcManager.invokeRemotely(java.util.Collection, org.infinispan.commands.ReplicableCommand, boolean) except that the task is passed to the transport executor and a Future is returned.
void	RpcManagerImpl.invokeRemotelyInFuture(Collection<Address> recipients, ReplicableCommand rpc, boolean usePriorityQueue, NotifyingNotifiableFuture<Object> l, long timeout)
void	RpcManager.invokeRemotelyInFuture(Collection<Address> recipients, ReplicableCommand rpc, boolean usePriorityQueue, NotifyingNotifiableFuture<Object> future, long timeout) The same as RpcManager.invokeRemotelyInFuture(java.util.Collection, org.infinispan.commands.ReplicableCommand, boolean, org.infinispan.util.concurrent.NotifyingNotifiableFuture) except that you can specify a timeout.
void	RpcManagerImpl.invokeRemotelyInFuture(Collection<Address> recipients, ReplicableCommand rpc, boolean usePriorityQueue, NotifyingNotifiableFuture<Object> l, long timeout, boolean ignoreLeavers)
void	RpcManager.invokeRemotelyInFuture(Collection<Address> recipients, ReplicableCommand rpc, boolean usePriorityQueue, NotifyingNotifiableFuture<Object> future, long timeout, boolean ignoreLeavers) The same as RpcManager.invokeRemotelyInFuture(java.util.Collection, org.infinispan.commands.ReplicableCommand, boolean, org.infinispan.util.concurrent.NotifyingNotifiableFuture, long) except that you can specify a response mode.
void	RpcManagerImpl.invokeRemotelyInFuture(Collection<Address> recipients, ReplicableCommand rpc, NotifyingNotifiableFuture<Object> l)
void	RpcManager.invokeRemotelyInFuture(Collection<Address> recipients, ReplicableCommand rpc, NotifyingNotifiableFuture<Object> future) The same as RpcManager.invokeRemotely(java.util.Collection, org.infinispan.commands.ReplicableCommand, boolean) except that the task is passed to the transport executor and a Future is returned.

Uses of ReplicableCommand in org.infinispan.remoting.transport

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

Modifier and Type	Method and Description
BackupResponse	Transport.backupRemotely(Collection<XSiteBackup> backups, ReplicableCommand rpcCommand)
Map<Address,Response>	Transport.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter) Invokes an RPC call on other caches in the cluster.

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 and Description
BackupResponse	JGroupsTransport.backupRemotely(Collection<XSiteBackup> backups, ReplicableCommand rpcCommand)
org.jgroups.util.RspList<Object>	CommandAwareRpcDispatcher.broadcastRemoteCommands(ReplicableCommand command, org.jgroups.blocks.ResponseMode mode, long timeout, boolean anycasting, boolean oob, org.jgroups.blocks.RspFilter filter, boolean asyncMarshalling, boolean ignoreLeavers)
Response	CommandAwareRpcDispatcher.invokeRemoteCommand(org.jgroups.Address recipient, ReplicableCommand command, org.jgroups.blocks.ResponseMode mode, long timeout, boolean oob, boolean asyncMarshalling)
org.jgroups.util.RspList<Object>	CommandAwareRpcDispatcher.invokeRemoteCommands(List<org.jgroups.Address> recipients, ReplicableCommand command, org.jgroups.blocks.ResponseMode mode, long timeout, boolean anycasting, boolean oob, org.jgroups.blocks.RspFilter filter, boolean asyncMarshalling, boolean ignoreLeavers)
Map<Address,Response>	JGroupsTransport.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter)

Uses of ReplicableCommand in org.infinispan.statetransfer

Classes in org.infinispan.statetransfer that implement ReplicableCommand

Modifier and Type	Class and Description
class	StateRequestCommand This command is used by a StateConsumer to request transactions and cache entries from a StateProvider.
class	StateResponseCommand This command is used by a StateProvider to push cache entries to a StateConsumer.

Uses of ReplicableCommand in org.infinispan.topology

Classes in org.infinispan.topology that implement ReplicableCommand

Modifier and Type	Class and Description
class	CacheTopologyControlCommand A control command for all cache membership/rebalance operations.

Uses of ReplicableCommand in org.infinispan.util

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

Modifier and Type	Method and Description
Collection<Class<? extends ReplicableCommand>>	ModuleProperties.moduleCommands()
Collection<Class<? extends ReplicableCommand>>	ModuleProperties.moduleOnlyReplicableCommands()

Uses of ReplicableCommand in org.infinispan.util.logging

Methods in org.infinispan.util.logging with parameters of type ReplicableCommand

Modifier and Type	Method and Description
void	Log.exceptionHandlingCommand(ReplicableCommand cmd, Throwable t)

Uses of ReplicableCommand in org.infinispan.xsite

Classes in org.infinispan.xsite that implement ReplicableCommand

Modifier and Type	Class and Description
class	XSiteAdminCommand Command used for handling XSiteReplication administrative operations.