Uses of Interface
org.infinispan.commands.ReplicableCommand

Packages that use ReplicableCommand

org.infinispan.commands	Commands that operate on the cache, either locally or remotely.
org.infinispan.commands.control	Commands that control and coordinate certain cache operations, such as rehashing, state transfer and locking.
org.infinispan.commands.read	Commands that read data from the cache.
org.infinispan.commands.remote	Meta-commands that wrap other commands for remote execution.
org.infinispan.commands.tx	Commands that represent transactional lifecycle transitions.
org.infinispan.commands.write	Commands that alter the state of the cache.
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.

Uses of ReplicableCommand in org.infinispan.commands

Subinterfaces of ReplicableCommand in org.infinispan.commands

interface	DataCommand Commands of this type manipulate data in the cache.
interface	VisitableCommand A type of command that can accept Visitors, such as CommandInterceptors.

Methods in org.infinispan.commands that return ReplicableCommand

ReplicableCommand

RemoteCommandsFactory.fromStream(byte id, Object[] parameters) Creates an un-initialized command.

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

SingleRpcCommand	CommandsFactoryImpl.buildSingleRpcCommand(ReplicableCommand call)
SingleRpcCommand	CommandsFactory.buildSingleRpcCommand(ReplicableCommand call) Builds a SingleRpcCommand "envelope" containing a single ReplicableCommand
void	CommandsFactoryImpl.initializeReplicableCommand(ReplicableCommand c)
void	CommandsFactory.initializeReplicableCommand(ReplicableCommand command) 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

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

class	LockControlCommand LockControlCommand is a command that enables distributed locking across infinispan nodes.
class	RehashControlCommand A control command to coordinate rehashes that may occur when nodes join or leave a cluster, when DIST is used as a cache mode.
class	StateTransferControlCommand A command that informs caches participating in a state transfer of the various stages in the state transfer process.

Uses of ReplicableCommand in org.infinispan.commands.read

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

class	AbstractDataCommand
class	EntrySetCommand EntrySetCommand.
class	GetKeyValueCommand Implements functionality defined by Map.get(Object) and Map.containsKey(Object) operations
class	KeySetCommand KeySetCommand.
class	SizeCommand Command to calculate the size of the cache
class	ValuesCommand ValuesCommand.

Uses of ReplicableCommand in org.infinispan.commands.remote

Subinterfaces of ReplicableCommand in org.infinispan.commands.remote

interface

CacheRpcCommand The RpcManager only replicates commands wrapped in a CacheRpcCommand.

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

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

ReplicableCommand	SingleRpcCommand.getCommand()
ReplicableCommand[]	MultipleRpcCommand.getCommands()

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

protected Object

BaseRpcInvokingCommand.processVisitableCommand(ReplicableCommand cacheCommand)

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

SingleRpcCommand(String cacheName, ReplicableCommand command)

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

MultipleRpcCommand(List<ReplicableCommand> modifications, String cacheName)

Uses of ReplicableCommand in org.infinispan.commands.tx

Subinterfaces of ReplicableCommand in org.infinispan.commands.tx

interface

TransactionBoundaryCommand An transaction boundary command that allows the retrieval of an attached GlobalTransaction

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

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.

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

boolean

PrepareCommand.containsModificationType(Class<? extends ReplicableCommand> replicableCommandClass)

Uses of ReplicableCommand in org.infinispan.commands.write

Subinterfaces of ReplicableCommand in org.infinispan.commands.write

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

class	AbstractDataWriteCommand Stuff common to WriteCommands
class	ClearCommand
class	EvictCommand
class	InvalidateCommand Removes an entry from memory - never removes the entry.
class	InvalidateL1Command Invalidates an entry in a L1 cache (used with DIST mode)
class	PutKeyValueCommand Implements functionality defined by Map.put(Object, Object)
class	PutMapCommand
class	RemoveCommand
class	ReplaceCommand

Uses of ReplicableCommand in org.infinispan.remoting

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

void	ReplicationQueue.add(ReplicableCommand job) Adds a new method call.

Uses of ReplicableCommand in org.infinispan.remoting.rpc

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

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.
void	RpcManagerImpl.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, boolean sync)
void	RpcManager.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, boolean sync) Broadcasts an RPC command to a specified set of recipients
void	RpcManagerImpl.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, boolean sync, boolean usePriorityQueue)
void	RpcManager.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, boolean sync, boolean usePriorityQueue) Broadcasts an RPC command to a specified set of recipients
void	RpcManagerImpl.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, boolean sync, boolean usePriorityQueue, long timeout)
List<Response>	RpcManagerImpl.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout)
List<Response>	RpcManager.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout) Invokes an RPC call on other caches in the cluster.
List<Response>	RpcManagerImpl.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue)
List<Response>	RpcManager.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue) Invokes an RPC call on other caches in the cluster.
List<Response>	RpcManagerImpl.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter)
List<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, 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

List<Response>

Transport.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter, boolean supportReplay) 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

org.jgroups.util.RspList	CommandAwareRpcDispatcher.invokeRemoteCommands(Vector<org.jgroups.Address> dests, ReplicableCommand command, int mode, long timeout, boolean anycasting, boolean oob, org.jgroups.blocks.RspFilter filter, boolean supportReplay, boolean asyncMarshalling, boolean broadcast)
List<Response>	JGroupsTransport.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter, boolean supportReplay)