org.jboss.cache.commands
Class CommandsFactoryImpl

java.lang.Object
  extended by 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
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
CommandsFactoryImpl()
           
 
Method Summary
 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


Copyright © 2009 JBoss, a division of Red Hat. All Rights Reserved.