| 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.tx.totalorder | |
| 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.clustered | |
| org.infinispan.query.impl | |
| 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.stats.wrappers | |
| 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 |
| 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. |
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
ReplicableCommand |
RemoteCommandsFactory.fromStream(byte id,
Object[] parameters,
byte type)
Creates an un-initialized command.
|
| 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. |
| 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
|
| Modifier and Type | Class and Description |
|---|---|
class |
LockControlCommand
LockControlCommand is a command that enables distributed locking across infinispan nodes.
|
| 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. |
| 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.
|
| 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. |
| 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 |
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>
|
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. |
| Modifier and Type | Interface and Description |
|---|---|
interface |
CacheRpcCommand
The
RpcManager only replicates commands wrapped in a CacheRpcCommand. |
| 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. |
| Modifier and Type | Method and Description |
|---|---|
ReplicableCommand |
SingleRpcCommand.getCommand() |
ReplicableCommand[] |
MultipleRpcCommand.getCommands() |
| Modifier and Type | Method and Description |
|---|---|
protected Object |
BaseRpcInvokingCommand.processVisitableCommand(ReplicableCommand cacheCommand) |
| Constructor and Description |
|---|
SingleRpcCommand(String cacheName,
ReplicableCommand command) |
| Constructor and Description |
|---|
MultipleRpcCommand(List<ReplicableCommand> modifications,
String cacheName) |
| 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.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
TransactionBoundaryCommand
An transaction boundary command that allows the retrieval of an attached
GlobalTransaction |
| 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). |
| Modifier and Type | Interface and Description |
|---|---|
interface |
TotalOrderPrepareCommand
Interface with the utilities methods that the prepare command must have when Total Order based protocol is used
|
| Modifier and Type | Class and Description |
|---|---|
class |
TotalOrderCommitCommand
Commit Command used in the 2nd phase of 2PC.
|
class |
TotalOrderNonVersionedPrepareCommand
Command corresponding to the 1st phase of 2PC when Total Order based protocol is used.
|
class |
TotalOrderRollbackCommand
The 2nd phase command of 2PC, used when a transaction must be aborted.
|
class |
TotalOrderVersionedCommitCommand
Command corresponding to the 2nd phase of 2PC.
|
class |
TotalOrderVersionedPrepareCommand
Command corresponding to the 1st phase of 2PC when Total Order based protocol is used.
|
| 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
|
| 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 |
| Modifier and Type | Method and Description |
|---|---|
ReplicableCommand |
ReplicableCommandExternalizer.readObject(ObjectInput input) |
| Modifier and Type | Method and Description |
|---|---|
Set<Class<? extends ReplicableCommand>> |
ReplicableCommandExternalizer.getTypeClasses() |
| 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) |
| Modifier and Type | Class and Description |
|---|---|
class |
ClusteredQueryCommand
Encapsulates all rpc calls for distributed queries actions
|
| Modifier and Type | Method and Description |
|---|---|
ReplicableCommand |
CommandFactory.fromStream(byte commandId,
Object[] args) |
| Modifier and Type | Method and Description |
|---|---|
Map<Byte,Class<? extends ReplicableCommand>> |
CommandFactory.getModuleCommands() |
| Modifier and Type | Method and Description |
|---|---|
void |
CommandInitializer.initializeReplicableCommand(ReplicableCommand c,
boolean isRemote) |
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
protected List<ReplicableCommand> |
ReplicationQueueImpl.drainReplQueue() |
| Modifier and Type | Method and Description |
|---|---|
void |
ReplicationQueue.add(ReplicableCommand job)
Adds a new command to the replication queue.
|
void |
ReplicationQueueImpl.add(ReplicableCommand job) |
| Modifier and Type | Method and Description |
|---|---|
void |
RpcManager.broadcastRpcCommand(ReplicableCommand rpc,
boolean sync)
Deprecated.
this method may be removed in the future. Use
RpcManager.invokeRemotely(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions) |
void |
RpcManagerImpl.broadcastRpcCommand(ReplicableCommand rpc,
boolean sync) |
void |
RpcManager.broadcastRpcCommand(ReplicableCommand rpc,
boolean sync,
boolean usePriorityQueue)
Deprecated.
this method may be removed in the future. Use
RpcManager.invokeRemotely(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions) |
void |
RpcManagerImpl.broadcastRpcCommand(ReplicableCommand rpc,
boolean sync,
boolean usePriorityQueue) |
void |
RpcManager.broadcastRpcCommandInFuture(ReplicableCommand rpc,
boolean usePriorityQueue,
NotifyingNotifiableFuture<Object> future)
Deprecated.
this method may be removed in the future. Use
#invokeRemotelyInFuture(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions, org.infinispan.util.concurrent.NotifyingNotifiableFuture) |
void |
RpcManagerImpl.broadcastRpcCommandInFuture(ReplicableCommand rpc,
boolean usePriorityQueue,
NotifyingNotifiableFuture<Object> l) |
void |
RpcManager.broadcastRpcCommandInFuture(ReplicableCommand rpc,
NotifyingNotifiableFuture<Object> future)
Deprecated.
this method may be removed in the future. Use
#invokeRemotelyInFuture(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions, org.infinispan.util.concurrent.NotifyingNotifiableFuture) |
void |
RpcManagerImpl.broadcastRpcCommandInFuture(ReplicableCommand rpc,
NotifyingNotifiableFuture<Object> l) |
Map<Address,Response> |
RpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
boolean sync)
Deprecated.
this method may be removed in the future. Use
RpcManager.invokeRemotely(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions) |
Map<Address,Response> |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
boolean sync) |
Map<Address,Response> |
RpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
boolean sync,
boolean usePriorityQueue)
Deprecated.
this method may be removed in the future. Use
RpcManager.invokeRemotely(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions) |
Map<Address,Response> |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
boolean sync,
boolean usePriorityQueue) |
Map<Address,Response> |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
boolean sync,
boolean usePriorityQueue,
long timeout) |
Map<Address,Response> |
RpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout)
Deprecated.
this method may be removed in the future. Use
RpcManager.invokeRemotely(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions) |
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,
boolean usePriorityQueue)
Deprecated.
this method may be removed in the future. Use
RpcManager.invokeRemotely(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions) |
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,
ResponseFilter responseFilter)
Deprecated.
this method may be removed in the future. Use
RpcManager.invokeRemotely(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions) |
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 rpc,
RpcOptions options)
Invokes an RPC call on other caches in the cluster.
|
Map<Address,Response> |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
RpcOptions options) |
void |
RpcManager.invokeRemotelyInFuture(Collection<Address> recipients,
ReplicableCommand rpc,
boolean usePriorityQueue,
NotifyingNotifiableFuture<Object> future)
Deprecated.
this method may be removed in the future. Use
#invokeRemotelyInFuture(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions, org.infinispan.util.concurrent.NotifyingNotifiableFuture) |
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,
long timeout)
Deprecated.
this method may be removed in the future. Use
#invokeRemotelyInFuture(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions, org.infinispan.util.concurrent.NotifyingNotifiableFuture) |
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,
boolean ignoreLeavers)
Deprecated.
this method may be removed in the future. Use
#invokeRemotelyInFuture(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions, org.infinispan.util.concurrent.NotifyingNotifiableFuture) |
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,
NotifyingNotifiableFuture<Object> future)
Deprecated.
this method may be removed in the future. Use
#invokeRemotelyInFuture(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions, org.infinispan.util.concurrent.NotifyingNotifiableFuture) |
void |
RpcManagerImpl.invokeRemotelyInFuture(Collection<Address> recipients,
ReplicableCommand rpc,
NotifyingNotifiableFuture<Object> l) |
void |
RpcManager.invokeRemotelyInFuture(Collection<Address> recipients,
ReplicableCommand rpc,
RpcOptions options,
NotifyingNotifiableFuture<Object> future)
The same as
RpcManager.invokeRemotely(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions)
except that the task is passed to the transport executor and a Future is returned. |
void |
RpcManagerImpl.invokeRemotelyInFuture(Collection<Address> recipients,
ReplicableCommand rpc,
RpcOptions options,
NotifyingNotifiableFuture<Object> future) |
| Modifier and Type | Method and Description |
|---|---|
BackupResponse |
AbstractDelegatingTransport.backupRemotely(Collection<XSiteBackup> backups,
ReplicableCommand rpcCommand) |
BackupResponse |
Transport.backupRemotely(Collection<XSiteBackup> backups,
ReplicableCommand rpcCommand) |
Map<Address,Response> |
AbstractDelegatingTransport.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter,
boolean totalOrder,
boolean anycast) |
Map<Address,Response> |
Transport.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter,
boolean totalOrder,
boolean anycast)
Invokes an RPC call on other caches in the cluster.
|
| 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 oob,
org.jgroups.blocks.RspFilter filter,
boolean asyncMarshalling,
boolean ignoreLeavers,
boolean totalOrder) |
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 oob,
org.jgroups.blocks.RspFilter filter,
boolean asyncMarshalling,
boolean ignoreLeavers,
boolean totalOrder) |
Map<Address,Response> |
JGroupsTransport.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter,
boolean totalOrder,
boolean anycast) |
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ExtendedStatisticRpcManager.broadcastRpcCommand(ReplicableCommand rpc,
boolean sync) |
void |
ExtendedStatisticRpcManager.broadcastRpcCommand(ReplicableCommand rpc,
boolean sync,
boolean usePriorityQueue) |
void |
ExtendedStatisticRpcManager.broadcastRpcCommandInFuture(ReplicableCommand rpc,
boolean usePriorityQueue,
NotifyingNotifiableFuture<Object> future) |
void |
ExtendedStatisticRpcManager.broadcastRpcCommandInFuture(ReplicableCommand rpc,
NotifyingNotifiableFuture<Object> future) |
Map<Address,Response> |
ExtendedStatisticRpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
boolean sync) |
Map<Address,Response> |
ExtendedStatisticRpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
boolean sync,
boolean usePriorityQueue) |
Map<Address,Response> |
ExtendedStatisticRpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout) |
Map<Address,Response> |
ExtendedStatisticRpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue) |
Map<Address,Response> |
ExtendedStatisticRpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter) |
Map<Address,Response> |
ExtendedStatisticRpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
RpcOptions options) |
void |
ExtendedStatisticRpcManager.invokeRemotelyInFuture(Collection<Address> recipients,
ReplicableCommand rpc,
boolean usePriorityQueue,
NotifyingNotifiableFuture<Object> future) |
void |
ExtendedStatisticRpcManager.invokeRemotelyInFuture(Collection<Address> recipients,
ReplicableCommand rpc,
boolean usePriorityQueue,
NotifyingNotifiableFuture<Object> future,
long timeout) |
void |
ExtendedStatisticRpcManager.invokeRemotelyInFuture(Collection<Address> recipients,
ReplicableCommand rpc,
boolean usePriorityQueue,
NotifyingNotifiableFuture<Object> future,
long timeout,
boolean ignoreLeavers) |
void |
ExtendedStatisticRpcManager.invokeRemotelyInFuture(Collection<Address> recipients,
ReplicableCommand rpc,
NotifyingNotifiableFuture<Object> future) |
void |
ExtendedStatisticRpcManager.invokeRemotelyInFuture(Collection<Address> recipients,
ReplicableCommand rpc,
RpcOptions options,
NotifyingNotifiableFuture<Object> future) |
| Modifier and Type | Class and Description |
|---|---|
class |
CacheTopologyControlCommand
A control command for all cache membership/rebalance operations.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<Class<? extends ReplicableCommand>> |
ModuleProperties.moduleCommands() |
Collection<Class<? extends ReplicableCommand>> |
ModuleProperties.moduleOnlyReplicableCommands() |
| Modifier and Type | Method and Description |
|---|---|
void |
Log.exceptionHandlingCommand(ReplicableCommand cmd,
Throwable t) |
void |
Log.shutdownHandlingCommand(ReplicableCommand command) |
| Modifier and Type | Class and Description |
|---|---|
class |
XSiteAdminCommand
Command used for handling XSiteReplication administrative operations.
|
Copyright © 2014 JBoss, a division of Red Hat. All Rights Reserved.