public class CommandsFactoryImpl extends Object implements CommandsFactory
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 and Description |
---|
CommandsFactoryImpl() |
protected RPCManager rpcManager
protected DataContainer dataContainer
protected Notifier notifier
protected InterceptorChain invoker
protected BuddyManager buddyManager
protected TransactionTable transactionTable
protected CacheSPI cacheSpi
protected Configuration configuration
protected TransactionManager txManager
protected BuddyFqnTransformer buddyFqnTransformer
public void initialize(RPCManager rpc, DataContainer dataContainer, Notifier notifier, BuddyManager buddyManager, InterceptorChain invoker, TransactionTable transactionTable, CacheSPI cacheSpi, Configuration configuration, TransactionManager txManager, BuddyFqnTransformer buddyFqnTransformer)
public StateTransferControlCommand buildStateTransferControlCommand(boolean enabled)
buildStateTransferControlCommand
in interface CommandsFactory
public PutDataMapCommand buildPutDataMapCommand(GlobalTransaction gtx, Fqn fqn, Map data)
buildPutDataMapCommand
in interface CommandsFactory
public PutKeyValueCommand buildPutKeyValueCommand(GlobalTransaction gtx, Fqn fqn, Object key, Object value)
buildPutKeyValueCommand
in interface CommandsFactory
public PutForExternalReadCommand buildPutForExternalReadCommand(GlobalTransaction gtx, Fqn fqn, Object key, Object value)
buildPutForExternalReadCommand
in interface CommandsFactory
public ReplicateCommand buildReplicateCommand(ReplicableCommand command)
buildReplicateCommand
in interface CommandsFactory
public ReplicateCommand buildReplicateCommand(List<ReplicableCommand> modifications)
buildReplicateCommand
in interface CommandsFactory
public PrepareCommand buildPrepareCommand(GlobalTransaction gtx, WriteCommand command, boolean onePhaseCommit)
buildPrepareCommand
in interface CommandsFactory
public PrepareCommand buildPrepareCommand(GlobalTransaction gtx, List<WriteCommand> modifications, org.jgroups.Address address, boolean onePhaseCommit)
buildPrepareCommand
in interface CommandsFactory
public CommitCommand buildCommitCommand(GlobalTransaction gtx)
buildCommitCommand
in interface CommandsFactory
public DataGravitationCleanupCommand buildDataGravitationCleanupCommand(Fqn primaryFqn, Fqn backupFqn)
buildDataGravitationCleanupCommand
in interface CommandsFactory
public GravitateDataCommand buildGravitateDataCommand(Fqn fqn, Boolean searchSubtrees)
buildGravitateDataCommand
in interface CommandsFactory
public EvictCommand buildEvictFqnCommand(Fqn fqn)
buildEvictFqnCommand
in interface CommandsFactory
public InvalidateCommand buildInvalidateCommand(Fqn fqn)
buildInvalidateCommand
in interface CommandsFactory
public GetDataMapCommand buildGetDataMapCommand(Fqn fqn)
buildGetDataMapCommand
in interface CommandsFactory
public ExistsCommand buildExistsNodeCommand(Fqn fqn)
buildExistsNodeCommand
in interface CommandsFactory
public GetKeyValueCommand buildGetKeyValueCommand(Fqn fqn, Object key, boolean sendNodeEvent)
buildGetKeyValueCommand
in interface CommandsFactory
public GetNodeCommand buildGetNodeCommand(Fqn fqn)
buildGetNodeCommand
in interface CommandsFactory
public GetKeysCommand buildGetKeysCommand(Fqn fqn)
buildGetKeysCommand
in interface CommandsFactory
public GetChildrenNamesCommand buildGetChildrenNamesCommand(Fqn fqn)
buildGetChildrenNamesCommand
in interface CommandsFactory
public RollbackCommand buildRollbackCommand(GlobalTransaction gtx)
buildRollbackCommand
in interface CommandsFactory
public OptimisticPrepareCommand buildOptimisticPrepareCommand(GlobalTransaction gtx, List<WriteCommand> modifications, org.jgroups.Address address, boolean onePhaseCommit)
buildOptimisticPrepareCommand
in interface CommandsFactory
public AnnounceBuddyPoolNameCommand buildAnnounceBuddyPoolNameCommand(org.jgroups.Address address, String buddyPoolName)
buildAnnounceBuddyPoolNameCommand
in interface CommandsFactory
public RemoveFromBuddyGroupCommand buildRemoveFromBuddyGroupCommand(String groupName)
buildRemoveFromBuddyGroupCommand
in interface CommandsFactory
public AssignToBuddyGroupCommand buildAssignToBuddyGroupCommand(BuddyGroup group, Map<Fqn,byte[]> state)
buildAssignToBuddyGroupCommand
in interface CommandsFactory
public ClusteredGetCommand buildClusteredGetCommand(Boolean searchBackupSubtrees, DataCommand dataCommand)
buildClusteredGetCommand
in interface CommandsFactory
public RemoveNodeCommand buildRemoveNodeCommand(GlobalTransaction gtx, Fqn fqn)
buildRemoveNodeCommand
in interface CommandsFactory
public ClearDataCommand buildClearDataCommand(GlobalTransaction gtx, Fqn fqn)
buildClearDataCommand
in interface CommandsFactory
public RemoveKeyCommand buildRemoveKeyCommand(GlobalTransaction tx, Fqn fqn, Object key)
buildRemoveKeyCommand
in interface CommandsFactory
public MoveCommand buildMoveCommand(Fqn from, Fqn to)
buildMoveCommand
in interface CommandsFactory
public CreateNodeCommand buildCreateNodeCommand(Fqn fqn)
buildCreateNodeCommand
in interface CommandsFactory
public ReplicableCommand fromStream(int id, Object[] parameters)
CommandsFactory
fromStream
in interface CommandsFactory
id
- id of the command to buildparameters
- parameters attached to the commandCopyright © 2012 JBoss, a division of Red Hat. All Rights Reserved.