|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use ReplicableCommand | |
---|---|
org.infinispan.commands | Commands that operate on the cache, either locally or remotely. |
org.infinispan.commands.control | |
org.infinispan.commands.read | |
org.infinispan.commands.remote | |
org.infinispan.commands.tx | |
org.infinispan.commands.write | |
org.infinispan.remoting | Remote communication between cache instances. |
org.infinispan.remoting.rpc | |
org.infinispan.remoting.transport | |
org.infinispan.remoting.transport.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 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 |
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
// TODO: MANIK: Document this |
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
// TODO: MANIK: Document this |
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
// TODO: MANIK: Document this |
class |
PrepareCommand
Command coresponding to the 1st phase of 2PC. |
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 |
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)
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(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter,
boolean supportReplay)
|
|
Google Analytics | |||||||||
PREV NEXT | FRAMES NO FRAMES |