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.
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 |
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
CommandsFactoryImpl
public CommandsFactoryImpl()
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 buildparameters
- parameters attached to the command
- Returns:
- a newly constructed cache command
Copyright © 2009 JBoss, a division of Red Hat. All Rights Reserved.