org.jboss.cache.commands

Class CommandsFactoryImpl

java.lang.Object

org.jboss.cache.commands.CommandsFactoryImpl

All Implemented Interfaces:

CommandsFactory

Direct Known Subclasses:

OptimisticCommandsFactoryImpl

public class CommandsFactoryImpl
extends Object
implements CommandsFactory

This is the implementation to use for most commands and most locking schemes.

Field Summary

Fields

Modifier and Type	Field and Description
protected BuddyFqnTransformer	buddyFqnTransformer
protected BuddyManager	buddyManager
protected CacheSPI	cacheSpi
protected Configuration	configuration
protected DataContainer	dataContainer
protected InterceptorChain	invoker
protected Notifier	notifier
protected RPCManager	rpcManager
protected TransactionTable	transactionTable
protected TransactionManager	txManager

Constructor Summary

Constructors

Constructor and Description
CommandsFactoryImpl()

Method Summary

Methods

Modifier and Type	Method and Description
AnnounceBuddyPoolNameCommand	buildAnnounceBuddyPoolNameCommand(org.jgroups.Address address, String buddyPoolName)
AssignToBuddyGroupCommand	buildAssignToBuddyGroupCommand(BuddyGroup group, Map<Fqn,byte[]> state)
ClearDataCommand	buildClearDataCommand(GlobalTransaction gtx, Fqn fqn)
ClusteredGetCommand	buildClusteredGetCommand(Boolean searchBackupSubtrees, DataCommand dataCommand)
CommitCommand	buildCommitCommand(GlobalTransaction gtx)
CreateNodeCommand	buildCreateNodeCommand(Fqn fqn)
DataGravitationCleanupCommand	buildDataGravitationCleanupCommand(Fqn primaryFqn, Fqn backupFqn)
EvictCommand	buildEvictFqnCommand(Fqn fqn)
ExistsCommand	buildExistsNodeCommand(Fqn fqn)
GetChildrenNamesCommand	buildGetChildrenNamesCommand(Fqn fqn)
GetDataMapCommand	buildGetDataMapCommand(Fqn fqn)
GetKeysCommand	buildGetKeysCommand(Fqn fqn)
GetKeyValueCommand	buildGetKeyValueCommand(Fqn fqn, Object key, boolean sendNodeEvent)
GetNodeCommand	buildGetNodeCommand(Fqn fqn)
GravitateDataCommand	buildGravitateDataCommand(Fqn fqn, Boolean searchSubtrees)
InvalidateCommand	buildInvalidateCommand(Fqn fqn)
MoveCommand	buildMoveCommand(Fqn from, Fqn to)
OptimisticPrepareCommand	buildOptimisticPrepareCommand(GlobalTransaction gtx, List<WriteCommand> modifications, org.jgroups.Address address, boolean onePhaseCommit)
PrepareCommand	buildPrepareCommand(GlobalTransaction gtx, List<WriteCommand> modifications, org.jgroups.Address address, boolean onePhaseCommit)
PrepareCommand	buildPrepareCommand(GlobalTransaction gtx, WriteCommand command, boolean onePhaseCommit)
PutDataMapCommand	buildPutDataMapCommand(GlobalTransaction gtx, Fqn fqn, Map data)
PutForExternalReadCommand	buildPutForExternalReadCommand(GlobalTransaction gtx, Fqn fqn, Object key, Object value)
PutKeyValueCommand	buildPutKeyValueCommand(GlobalTransaction gtx, Fqn fqn, Object key, Object value)
RemoveFromBuddyGroupCommand	buildRemoveFromBuddyGroupCommand(String groupName)
RemoveKeyCommand	buildRemoveKeyCommand(GlobalTransaction tx, Fqn fqn, Object key)
RemoveNodeCommand	buildRemoveNodeCommand(GlobalTransaction gtx, Fqn fqn)
ReplicateCommand	buildReplicateCommand(List<ReplicableCommand> modifications)
ReplicateCommand	buildReplicateCommand(ReplicableCommand command)
RollbackCommand	buildRollbackCommand(GlobalTransaction gtx)
StateTransferControlCommand	buildStateTransferControlCommand(boolean enabled)
ReplicableCommand	fromStream(int id, Object[] parameters) Builds a cache command based on the ID passed in and an object array of parameters
void	initialize(RPCManager rpc, DataContainer dataContainer, Notifier notifier, BuddyManager buddyManager, InterceptorChain invoker, TransactionTable transactionTable, CacheSPI cacheSpi, Configuration configuration, TransactionManager txManager, BuddyFqnTransformer buddyFqnTransformer)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

rpcManager

protected RPCManager rpcManager

dataContainer

protected DataContainer dataContainer

notifier

protected Notifier notifier

invoker

protected InterceptorChain invoker

buddyManager

protected BuddyManager buddyManager

transactionTable

protected TransactionTable transactionTable

cacheSpi

protected CacheSPI cacheSpi

configuration

protected Configuration configuration

txManager

protected TransactionManager txManager

buddyFqnTransformer

protected BuddyFqnTransformer buddyFqnTransformer

Constructor Detail

CommandsFactoryImpl

public CommandsFactoryImpl()

Method Detail

initialize

public void initialize(RPCManager rpc,
              DataContainer dataContainer,
              Notifier notifier,
              BuddyManager buddyManager,
              InterceptorChain invoker,
              TransactionTable transactionTable,
              CacheSPI cacheSpi,
              Configuration configuration,
              TransactionManager txManager,
              BuddyFqnTransformer buddyFqnTransformer)

buildStateTransferControlCommand

public StateTransferControlCommand buildStateTransferControlCommand(boolean enabled)

Specified by:

buildStateTransferControlCommand in interface CommandsFactory

buildPutDataMapCommand

public PutDataMapCommand buildPutDataMapCommand(GlobalTransaction gtx,
                                       Fqn fqn,
                                       Map data)

Specified by:

buildPutDataMapCommand in interface CommandsFactory

buildPutKeyValueCommand

public PutKeyValueCommand buildPutKeyValueCommand(GlobalTransaction gtx,
                                         Fqn fqn,
                                         Object key,
                                         Object value)

Specified by:

buildPutKeyValueCommand in interface CommandsFactory

buildPutForExternalReadCommand

public PutForExternalReadCommand buildPutForExternalReadCommand(GlobalTransaction gtx,
                                                       Fqn fqn,
                                                       Object key,
                                                       Object value)

Specified by:

buildPutForExternalReadCommand in interface CommandsFactory

buildReplicateCommand

public ReplicateCommand buildReplicateCommand(ReplicableCommand command)

Specified by:

buildReplicateCommand in interface CommandsFactory

buildReplicateCommand

public ReplicateCommand buildReplicateCommand(List<ReplicableCommand> modifications)

Specified by:

buildReplicateCommand in interface CommandsFactory

buildPrepareCommand

public PrepareCommand buildPrepareCommand(GlobalTransaction gtx,
                                 WriteCommand command,
                                 boolean onePhaseCommit)

Specified by:

buildPrepareCommand in interface CommandsFactory

buildPrepareCommand

public PrepareCommand buildPrepareCommand(GlobalTransaction gtx,
                                 List<WriteCommand> modifications,
                                 org.jgroups.Address address,
                                 boolean onePhaseCommit)

Specified by:

buildPrepareCommand in interface CommandsFactory

buildCommitCommand

public CommitCommand buildCommitCommand(GlobalTransaction gtx)

Specified by:

buildCommitCommand in interface CommandsFactory

buildDataGravitationCleanupCommand

public DataGravitationCleanupCommand buildDataGravitationCleanupCommand(Fqn primaryFqn,
                                                               Fqn backupFqn)

Specified by:

buildDataGravitationCleanupCommand in interface CommandsFactory

buildGravitateDataCommand

public GravitateDataCommand buildGravitateDataCommand(Fqn fqn,
                                             Boolean searchSubtrees)

Specified by:

buildGravitateDataCommand in interface CommandsFactory

buildEvictFqnCommand

public EvictCommand buildEvictFqnCommand(Fqn fqn)

Specified by:

buildEvictFqnCommand in interface CommandsFactory

buildInvalidateCommand

public InvalidateCommand buildInvalidateCommand(Fqn fqn)

Specified by:

buildInvalidateCommand in interface CommandsFactory

buildGetDataMapCommand

public GetDataMapCommand buildGetDataMapCommand(Fqn fqn)

Specified by:

buildGetDataMapCommand in interface CommandsFactory

buildExistsNodeCommand

public ExistsCommand buildExistsNodeCommand(Fqn fqn)

Specified by:

buildExistsNodeCommand in interface CommandsFactory

buildGetKeyValueCommand

public GetKeyValueCommand buildGetKeyValueCommand(Fqn fqn,
                                         Object key,
                                         boolean sendNodeEvent)

Specified by:

buildGetKeyValueCommand in interface CommandsFactory

buildGetNodeCommand

public GetNodeCommand buildGetNodeCommand(Fqn fqn)

Specified by:

buildGetNodeCommand in interface CommandsFactory

buildGetKeysCommand

public GetKeysCommand buildGetKeysCommand(Fqn fqn)

Specified by:

buildGetKeysCommand in interface CommandsFactory

buildGetChildrenNamesCommand

public GetChildrenNamesCommand buildGetChildrenNamesCommand(Fqn fqn)

Specified by:

buildGetChildrenNamesCommand in interface CommandsFactory

buildRollbackCommand

public RollbackCommand buildRollbackCommand(GlobalTransaction gtx)

Specified by:

buildRollbackCommand in interface CommandsFactory

buildOptimisticPrepareCommand

public OptimisticPrepareCommand buildOptimisticPrepareCommand(GlobalTransaction gtx,
                                                     List<WriteCommand> modifications,
                                                     org.jgroups.Address address,
                                                     boolean onePhaseCommit)

Specified by:

buildOptimisticPrepareCommand in interface CommandsFactory

buildAnnounceBuddyPoolNameCommand

public AnnounceBuddyPoolNameCommand buildAnnounceBuddyPoolNameCommand(org.jgroups.Address address,
                                                             String buddyPoolName)

Specified by:

buildAnnounceBuddyPoolNameCommand in interface CommandsFactory

buildRemoveFromBuddyGroupCommand

public RemoveFromBuddyGroupCommand buildRemoveFromBuddyGroupCommand(String groupName)

Specified by:

buildRemoveFromBuddyGroupCommand in interface CommandsFactory

buildAssignToBuddyGroupCommand

public AssignToBuddyGroupCommand buildAssignToBuddyGroupCommand(BuddyGroup group,
                                                       Map<Fqn,byte[]> state)

Specified by:

buildAssignToBuddyGroupCommand in interface CommandsFactory

buildClusteredGetCommand

public ClusteredGetCommand buildClusteredGetCommand(Boolean searchBackupSubtrees,
                                           DataCommand dataCommand)

Specified by:

buildClusteredGetCommand in interface CommandsFactory

buildRemoveNodeCommand

public RemoveNodeCommand buildRemoveNodeCommand(GlobalTransaction gtx,
                                       Fqn fqn)

Specified by:

buildRemoveNodeCommand in interface CommandsFactory

buildClearDataCommand

public ClearDataCommand buildClearDataCommand(GlobalTransaction gtx,
                                     Fqn fqn)

Specified by:

buildClearDataCommand in interface CommandsFactory

buildRemoveKeyCommand

public RemoveKeyCommand buildRemoveKeyCommand(GlobalTransaction tx,
                                     Fqn fqn,
                                     Object key)

Specified by:

buildRemoveKeyCommand in interface CommandsFactory

buildMoveCommand

public MoveCommand buildMoveCommand(Fqn from,
                           Fqn to)

Specified by:

buildMoveCommand in interface CommandsFactory

buildCreateNodeCommand

public CreateNodeCommand buildCreateNodeCommand(Fqn fqn)

Specified by:

buildCreateNodeCommand in interface CommandsFactory

fromStream

public ReplicableCommand fromStream(int id,
                           Object[] parameters)

Description copied from interface: CommandsFactory

Builds a cache command based on the ID passed in and an object array of parameters

Specified by:

fromStream in interface CommandsFactory

Parameters:

id - id of the command to build

parameters - parameters attached to the command

Returns:

a newly constructed cache command