|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
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 |
TransactionBoundaryCommand
// TODO: MANIK: Document this |
interface |
VisitableCommand
A type of command that can accept Visitor s, such as CommandInterceptor s. |
Methods in org.infinispan.commands that return ReplicableCommand | |
---|---|
ReplicableCommand |
RemoteCommandFactory.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)
|
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)
|
Uses of ReplicableCommand in org.infinispan.commands.control |
---|
Classes in org.infinispan.commands.control that implement ReplicableCommand | |
---|---|
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 |
GetKeyValueCommand
// TODO: MANIK: Document this |
class |
SizeCommand
Command to calculate the size of the cache |
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
Base class for RPC commands. |
class |
ClusteredGetCommand
Issues a clustered get call, for use primarily by the ClusteredCacheLoader . |
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 |
BaseRpcCommand.processCommand(InvocationContext ctx,
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 |
---|
Classes in org.infinispan.commands.tx that implement ReplicableCommand | |
---|---|
class |
AbstractTransactionBoundaryCommand
// TODO: MANIK: Document this |
class |
CommitCommand
// TODO: MANIK: Document this |
class |
PrepareCommand
// TODO: MANIK: Document this |
class |
RollbackCommand
// TODO: MANIK: Document this |
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 |
ClearCommand
|
class |
EvictCommand
|
class |
InvalidateCommand
Removes an entry from memory - never removes the entry. |
class |
PutKeyValueCommand
Implements functionality defined by Map.put(Object, Object) |
class |
PutMapCommand
|
class |
RemoveCommand
|
class |
ReplaceCommand
|
Uses of ReplicableCommand in org.infinispan.interceptors.base |
---|
Methods in org.infinispan.interceptors.base with parameters of type ReplicableCommand | |
---|---|
protected void |
BaseRpcInterceptor.replicateCall(InvocationContext ctx,
List<Address> recipients,
ReplicableCommand c,
boolean sync,
boolean useOutOfBandMessage)
|
protected void |
BaseRpcInterceptor.replicateCall(InvocationContext ctx,
ReplicableCommand call,
boolean sync)
|
protected void |
BaseRpcInterceptor.replicateCall(InvocationContext ctx,
ReplicableCommand call,
boolean sync,
boolean useOutOfBandMessage)
|
protected void |
BaseRpcInterceptor.replicateCall(List<Address> recipients,
ReplicableCommand call,
boolean sync,
boolean useOutOfBandMessage,
long timeout)
|
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. |
List<Response> |
RpcManagerImpl.invokeRemotely(List<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean stateTransferEnabled)
|
List<Response> |
RpcManager.invokeRemotely(List<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean stateTransferEnabled)
Invokes an RPC call on other caches in the cluster. |
List<Response> |
RpcManagerImpl.invokeRemotely(List<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
boolean stateTransferEnabled)
|
List<Response> |
RpcManager.invokeRemotely(List<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
boolean stateTransferEnabled)
Invokes an RPC call on other caches in the cluster. |
List<Response> |
RpcManagerImpl.invokeRemotely(List<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter,
boolean stateTransferEnabled)
|
List<Response> |
RpcManager.invokeRemotely(List<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter,
boolean stateTransferEnabled)
Invokes an RPC call on other caches in the cluster. |
Uses of ReplicableCommand in org.infinispan.remoting.transport |
---|
Methods in org.infinispan.remoting.transport with parameters of type ReplicableCommand | |
---|---|
List<Response> |
Transport.invokeRemotely(List<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)
Similar to RpcDispatcher.callRemoteMethods(java.util.Vector, org.jgroups.blocks.MethodCall, int, long, boolean, boolean,
org.jgroups.blocks.RspFilter) except that this version is aware of ReplicableCommand objects. |
List<Response> |
JGroupsTransport.invokeRemotely(List<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter,
boolean supportReplay)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |