org.infinispan.commands

Class CommandsFactoryImpl

java.lang.Object

org.infinispan.commands.CommandsFactoryImpl

All Implemented Interfaces:

CommandsFactory

public class CommandsFactoryImpl
extends Object
implements CommandsFactory

Since:

4.0

Author:

Mircea.Markus@jboss.com, Galder Zamarreño, Sanne Grinovero (C) 2011 Red Hat Inc.

Constructor Summary

Constructors

Constructor and Description
CommandsFactoryImpl()

Method Summary

Modifier and Type	Method and Description
ApplyDeltaCommand	buildApplyDeltaCommand(Object deltaAwareValueKey, Delta delta, Collection keys) Builds a ApplyDeltaCommand used for applying Delta objects to DeltaAware containers stored in cache
CancelCommand	buildCancelCommandCommand(UUID commandUUID) Builds CancelCommandCommand used to cancel other commands executing on Infinispan cluster
ClearCommand	buildClearCommand(Set<Flag> flags) Builds a ClearCommand
ClusteredGetAllCommand	buildClusteredGetAllCommand(List<?> keys, Set<Flag> flags, GlobalTransaction gtx) Builds a ClusteredGetAllCommand, which is a remote lookup command
ClusteredGetCommand	buildClusteredGetCommand(Object key, Set<Flag> flags, boolean acquireRemoteLock, GlobalTransaction gtx) Builds a ClusteredGetCommand, which is a remote lookup command
CommitCommand	buildCommitCommand(GlobalTransaction gtx) Builds a CommitCommand
CompleteTransactionCommand	buildCompleteTransactionCommand(Xid xid, boolean commit) Builds a CompleteTransactionCommand command.
CreateCacheCommand	buildCreateCacheCommand(String cacheNameToCreate, String cacheConfigurationName) Same as buildCreateCacheCommand(cacheName, cacheConfigurationName, false, 0).
CreateCacheCommand	buildCreateCacheCommand(String cacheNameToCreate, String cacheConfigurationName, int size) Builds a CreateCacheCommand used to create/start cache around Infinispan cluster
<T> DistributedExecuteCommand<T>	buildDistributedExecuteCommand(Callable<T> callable, Address sender, Collection keys) Builds a DistributedExecuteCommand used for migration and execution of distributed Callables and Runnables.
<K,V,C> EntryRequestCommand<K,V,C>	buildEntryRequestCommand(UUID identifier, Set<Integer> segments, Set<K> keysToFilter, KeyValueFilter<? super K,? super V> filter, Converter<? super K,? super V,C> converter, Set<Flag> flags) Builds EntryRequestCommand used to request entries from a remote node for given segments
<K,C> EntryResponseCommand<K,C>	buildEntryResponseCommand(UUID identifier, Set<Integer> completedSegments, Set<Integer> inDoubtSegments, Collection<CacheEntry<K,C>> values, CacheException e) Builds EntryResponseCommand use to respond with retrieved entries for given segments
EntrySetCommand	buildEntrySetCommand(Set<Flag> flags) Builds a EntrySetCommand
EvictCommand	buildEvictCommand(Object key, Set<Flag> flags) Builds an EvictCommand
GetAllCommand	buildGetAllCommand(Collection<?> keys, Set<Flag> flags, boolean returnEntries) Builds a GetAllCommand
GetCacheEntryCommand	buildGetCacheEntryCommand(Object key, Set<Flag> explicitFlags) Builds a GetCacheEntryCommand
GetInDoubtTransactionsCommand	buildGetInDoubtTransactionsCommand() Builds a GetInDoubtTransactionsCommand.
GetInDoubtTxInfoCommand	buildGetInDoubtTxInfoCommand()
GetKeysInGroupCommand	buildGetKeysInGroupCommand(Set<Flag> flags, String groupName) Builds GetKeysInGroupCommand used to fetch all the keys belonging to a group.
GetKeyValueCommand	buildGetKeyValueCommand(Object key, Set<Flag> flags) Builds a GetKeyValueCommand
InvalidateCommand	buildInvalidateCommand(Set<Flag> flags, Object... keys) Builds an InvalidateCommand
InvalidateCommand	buildInvalidateFromL1Command(Address origin, Set<Flag> flags, Collection<Object> keys)
InvalidateCommand	buildInvalidateFromL1Command(Set<Flag> flags, Collection<Object> keys) Builds an InvalidateFromL1Command
KeySetCommand	buildKeySetCommand(Set<Flag> flags) Builds a KeySetCommand
LockControlCommand	buildLockControlCommand(Collection<?> keys, Set<Flag> flags)
LockControlCommand	buildLockControlCommand(Collection<?> keys, Set<Flag> flags, GlobalTransaction gtx) Builds a LockControlCommand to control explicit remote locking
LockControlCommand	buildLockControlCommand(Object key, Set<Flag> flags, GlobalTransaction gtx) Same as CommandsFactory.buildLockControlCommand(Object, java.util.Set, org.infinispan.transaction.xa.GlobalTransaction) but for locking a single key vs a collection of keys.
<KIn,VIn,KOut,VOut> MapCombineCommand<KIn,VIn,KOut,VOut>	buildMapCombineCommand(String taskId, Mapper<KIn,VIn,KOut,VOut> m, Reducer<KOut,VOut> r, Collection<KIn> keys) Builds a MapCombineCommand used for migration and map phase execution of MapReduce tasks.
PrepareCommand	buildPrepareCommand(GlobalTransaction gtx, List<WriteCommand> modifications, boolean onePhaseCommit) Builds a PrepareCommand
PutKeyValueCommand	buildPutKeyValueCommand(Object key, Object value, Metadata metadata, Set<Flag> flags) Builds a PutKeyValueCommand
PutMapCommand	buildPutMapCommand(Map<?,?> map, Metadata metadata, Set<Flag> flags) Builds a PutMapCommand
<K,V,R> ReadOnlyKeyCommand<K,V,R>	buildReadOnlyKeyCommand(K key, Function<EntryView.ReadEntryView<K,V>,R> f)
<K,V,R> ReadOnlyManyCommand<K,V,R>	buildReadOnlyManyCommand(Set<? extends K> keys, Function<EntryView.ReadEntryView<K,V>,R> f)
<K,V,R> ReadWriteKeyCommand<K,V,R>	buildReadWriteKeyCommand(K key, Function<EntryView.ReadWriteEntryView<K,V>,R> f, Params params)
<K,V,R> ReadWriteKeyValueCommand<K,V,R>	buildReadWriteKeyValueCommand(K key, V value, BiFunction<V,EntryView.ReadWriteEntryView<K,V>,R> f, Params params)
<K,V,R> ReadWriteManyCommand<K,V,R>	buildReadWriteManyCommand(Set<? extends K> keys, Function<EntryView.ReadWriteEntryView<K,V>,R> f, Params params)
<K,V,R> ReadWriteManyEntriesCommand<K,V,R>	buildReadWriteManyEntriesCommand(Map<? extends K,? extends V> entries, BiFunction<V,EntryView.ReadWriteEntryView<K,V>,R> f, Params params)
<KOut,VOut> ReduceCommand<KOut,VOut>	buildReduceCommand(String taskId, String destintationCache, Reducer<KOut,VOut> r, Collection<KOut> keys) Builds a ReduceCommand used for migration and reduce phase execution of MapReduce tasks.
RemoveCommand	buildRemoveCommand(Object key, Object value, Set<Flag> flags) Builds a RemoveCommand
RemoveExpiredCommand	buildRemoveExpiredCommand(Object key, Object value, Long lifespan) Builds an expired remove command that is used to remove only a specific expired entry
ReplaceCommand	buildReplaceCommand(Object key, Object oldValue, Object newValue, Metadata metadata, Set<Flag> flags) Builds a ReplaceCommand
MultipleRpcCommand	buildReplicateCommand(List<ReplicableCommand> toReplicate) Builds an RpcCommand "envelope" containing multiple ReplicableCommands
RollbackCommand	buildRollbackCommand(GlobalTransaction gtx) Builds a RollbackCommand
SingleRpcCommand	buildSingleRpcCommand(ReplicableCommand call) Builds a SingleRpcCommand "envelope" containing a single ReplicableCommand
SingleXSiteRpcCommand	buildSingleXSiteRpcCommand(VisitableCommand command) Builds SingleRpcCommand used to perform VisitableCommand on the backup site,
SizeCommand	buildSizeCommand(Set<Flag> flags) Builds a SizeCommand
StateRequestCommand	buildStateRequestCommand(StateRequestCommand.Type subtype, Address sender, int viewId, Set<Integer> segments) Builds a StateRequestCommand used for requesting transactions and locks and for starting or canceling transfer of cache entries.
StateResponseCommand	buildStateResponseCommand(Address sender, int topologyId, Collection<StateChunk> stateChunks) Builds a StateResponseCommand used for pushing cache entries to another node in response to a StateRequestCommand.
<K> StreamRequestCommand<K>	buildStreamRequestCommand(Object id, boolean parallelStream, StreamRequestCommand.Type type, Set<Integer> segments, Set<K> keys, Set<K> excludedKeys, boolean includeLoader, Object terminalOperation)
<R> StreamResponseCommand<R>	buildStreamResponseCommand(Object identifier, boolean complete, Set<Integer> lostSegments, R response) Builds StreamResponseCommand used to send back a response either intermediate or complete to the originating node with the information for the stream request.
TxCompletionNotificationCommand	buildTxCompletionNotificationCommand(long internalId)
TxCompletionNotificationCommand	buildTxCompletionNotificationCommand(Xid xid, GlobalTransaction globalTransaction) Builds a TxCompletionNotificationCommand.
VersionedCommitCommand	buildVersionedCommitCommand(GlobalTransaction gtx) Builds a VersionedCommitCommand
VersionedPrepareCommand	buildVersionedPrepareCommand(GlobalTransaction gtx, List<WriteCommand> modifications, boolean onePhase) Builds a VersionedPrepareCommand
<K,V> WriteOnlyKeyCommand<K,V>	buildWriteOnlyKeyCommand(K key, Consumer<EntryView.WriteEntryView<V>> f, Params params)
<K,V> WriteOnlyKeyValueCommand<K,V>	buildWriteOnlyKeyValueCommand(K key, V value, BiConsumer<V,EntryView.WriteEntryView<V>> f, Params params)
<K,V> WriteOnlyManyCommand<K,V>	buildWriteOnlyManyCommand(Set<? extends K> keys, Consumer<EntryView.WriteEntryView<V>> f, Params params)
<K,V> WriteOnlyManyEntriesCommand<K,V>	buildWriteOnlyManyEntriesCommand(Map<? extends K,? extends V> entries, BiConsumer<V,EntryView.WriteEntryView<V>> f, Params params)
XSiteAdminCommand	buildXSiteAdminCommand(String siteName, XSiteAdminCommand.AdminOperation op, Integer afterFailures, Long minTimeToWait) Builds XSiteAdminCommand used to perform system administrator operations.
XSiteStatePushCommand	buildXSiteStatePushCommand(XSiteState[] chunk, long timeoutMillis) Builds XSiteStatePushCommand used to transfer a single chunk of data between sites.
XSiteStateTransferControlCommand	buildXSiteStateTransferControlCommand(XSiteStateTransferControlCommand.StateTransferControl control, String siteName) Builds XSiteStateTransferControlCommand used to control the-cross site state transfer.
String	getCacheName() Retrieves the cache name this CommandFactory is set up to construct commands for.
void	initializeReplicableCommand(ReplicableCommand c, boolean isRemote) Initializes a ReplicableCommand read from a data stream with components specific to the target cache instance.
void	setupDependencies(DataContainer container, CacheNotifier<Object,Object> notifier, Cache<Object,Object> cache, InterceptorChain interceptorChain, DistributionManager distributionManager, InvocationContextFactory icf, TransactionTable txTable, Configuration configuration, Map<Byte,ModuleCommandInitializer> moduleCommandInitializers, RecoveryManager recoveryManager, StateProvider stateProvider, StateConsumer stateConsumer, LockManager lockManager, InternalEntryFactory entryFactory, MapReduceManager mapReduceManager, StateTransferManager stm, BackupSender backupSender, CancellationService cancellationService, TimeService timeService, XSiteStateProvider xSiteStateProvider, XSiteStateConsumer xSiteStateConsumer, XSiteStateTransferManager xSiteStateTransferManager, EntryRetriever entryRetriever, GroupManager groupManager, PartitionHandlingManager partitionHandlingManager, LocalStreamManager localStreamManager, ClusterStreamManager clusterStreamManager, ClusteringDependentLogic clusteringDependentLogic, ExternalizerTable externalizerTable)
void	start()

Methods inherited from class java.lang.Object

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

Constructor Detail

CommandsFactoryImpl

public CommandsFactoryImpl()

Method Detail

setupDependencies

public void setupDependencies(DataContainer container,
                              CacheNotifier<Object,Object> notifier,
                              Cache<Object,Object> cache,
                              InterceptorChain interceptorChain,
                              DistributionManager distributionManager,
                              InvocationContextFactory icf,
                              TransactionTable txTable,
                              Configuration configuration,
                              Map<Byte,ModuleCommandInitializer> moduleCommandInitializers,
                              RecoveryManager recoveryManager,
                              StateProvider stateProvider,
                              StateConsumer stateConsumer,
                              LockManager lockManager,
                              InternalEntryFactory entryFactory,
                              MapReduceManager mapReduceManager,
                              StateTransferManager stm,
                              BackupSender backupSender,
                              CancellationService cancellationService,
                              TimeService timeService,
                              XSiteStateProvider xSiteStateProvider,
                              XSiteStateConsumer xSiteStateConsumer,
                              XSiteStateTransferManager xSiteStateTransferManager,
                              EntryRetriever entryRetriever,
                              GroupManager groupManager,
                              PartitionHandlingManager partitionHandlingManager,
                              LocalStreamManager localStreamManager,
                              ClusterStreamManager clusterStreamManager,
                              ClusteringDependentLogic clusteringDependentLogic,
                              ExternalizerTable externalizerTable)

start

public void start()

buildPutKeyValueCommand

public PutKeyValueCommand buildPutKeyValueCommand(Object key,
                                                  Object value,
                                                  Metadata metadata,
                                                  Set<Flag> flags)

Description copied from interface: CommandsFactory

Builds a PutKeyValueCommand

Specified by:

buildPutKeyValueCommand in interface CommandsFactory

Parameters:

key - key to put

value - value to put

metadata - metadata of entry

flags - Command flags provided by cache

Returns:

a PutKeyValueCommand

buildRemoveCommand

public RemoveCommand buildRemoveCommand(Object key,
                                        Object value,
                                        Set<Flag> flags)

Description copied from interface: CommandsFactory

Builds a RemoveCommand

Specified by:

buildRemoveCommand in interface CommandsFactory

Parameters:

key - key to remove

value - value to check for ina conditional remove, or null for an unconditional remove.

flags - Command flags provided by cache

Returns:

a RemoveCommand

buildInvalidateCommand

public InvalidateCommand buildInvalidateCommand(Set<Flag> flags,
                                                Object... keys)

Description copied from interface: CommandsFactory

Builds an InvalidateCommand

Specified by:

buildInvalidateCommand in interface CommandsFactory

Parameters:

flags - Command flags provided by cache

keys - keys to invalidate

Returns:

an InvalidateCommand

buildInvalidateFromL1Command

public InvalidateCommand buildInvalidateFromL1Command(Set<Flag> flags,
                                                      Collection<Object> keys)

Description copied from interface: CommandsFactory

Builds an InvalidateFromL1Command

Specified by:

buildInvalidateFromL1Command in interface CommandsFactory

keys - keys to invalidate

Returns:

an InvalidateFromL1Command

buildInvalidateFromL1Command

public InvalidateCommand buildInvalidateFromL1Command(Address origin,
                                                      Set<Flag> flags,
                                                      Collection<Object> keys)

Specified by:

buildInvalidateFromL1Command in interface CommandsFactory

See Also:

CommandsFactory.buildInvalidateFromL1Command(java.util.Set, java.util.Collection)

buildRemoveExpiredCommand

public RemoveExpiredCommand buildRemoveExpiredCommand(Object key,
                                                      Object value,
                                                      Long lifespan)

Description copied from interface: CommandsFactory

Builds an expired remove command that is used to remove only a specific expired entry

Specified by:

buildRemoveExpiredCommand in interface CommandsFactory

Parameters:

key - the key of the expired entry

value - the value of the entry when it was expired

lifespan - the lifespan that expired from the command

Returns:

a RemovedExpiredCommand

buildReplaceCommand

public ReplaceCommand buildReplaceCommand(Object key,
                                          Object oldValue,
                                          Object newValue,
                                          Metadata metadata,
                                          Set<Flag> flags)

Description copied from interface: CommandsFactory

Builds a ReplaceCommand

Specified by:

buildReplaceCommand in interface CommandsFactory

Parameters:

key - key to replace

oldValue - existing value to check for if conditional, null if unconditional.

newValue - value to replace with

metadata - metadata of entry

flags - Command flags provided by cache

Returns:

a ReplaceCommand

buildSizeCommand

public SizeCommand buildSizeCommand(Set<Flag> flags)

Description copied from interface: CommandsFactory

Builds a SizeCommand

Specified by:

buildSizeCommand in interface CommandsFactory

Parameters:

flags - Command flags provided by cache

Returns:

a SizeCommand

buildKeySetCommand

public KeySetCommand buildKeySetCommand(Set<Flag> flags)

Description copied from interface: CommandsFactory

Builds a KeySetCommand

Specified by:

buildKeySetCommand in interface CommandsFactory

Parameters:

flags - Command flags provided by cache

Returns:

a KeySetCommand

buildEntrySetCommand

public EntrySetCommand buildEntrySetCommand(Set<Flag> flags)

Description copied from interface: CommandsFactory

Builds a EntrySetCommand

Specified by:

buildEntrySetCommand in interface CommandsFactory

Parameters:

flags - Command flags provided by cache

Returns:

a EntrySetCommand

buildGetKeyValueCommand

public GetKeyValueCommand buildGetKeyValueCommand(Object key,
                                                  Set<Flag> flags)

Description copied from interface: CommandsFactory

Builds a GetKeyValueCommand

Specified by:

buildGetKeyValueCommand in interface CommandsFactory

Parameters:

key - key to get

flags - Command flags provided by cache

Returns:

a GetKeyValueCommand

buildGetAllCommand

public GetAllCommand buildGetAllCommand(Collection<?> keys,
                                        Set<Flag> flags,
                                        boolean returnEntries)

Description copied from interface: CommandsFactory

Builds a GetAllCommand

Specified by:

buildGetAllCommand in interface CommandsFactory

Parameters:

keys - keys to get

flags - Command flags provided by cache

returnEntries - boolean indicating whether entire cache entries are returned, otherwise return just the value parts

Returns:

a GetKeyValueCommand

buildPutMapCommand

public PutMapCommand buildPutMapCommand(Map<?,?> map,
                                        Metadata metadata,
                                        Set<Flag> flags)

Description copied from interface: CommandsFactory

Builds a PutMapCommand

Specified by:

buildPutMapCommand in interface CommandsFactory

Parameters:

map - map containing key/value entries to put

metadata - metadata of entry

flags - Command flags provided by cache

Returns:

a PutMapCommand

buildClearCommand

public ClearCommand buildClearCommand(Set<Flag> flags)

Description copied from interface: CommandsFactory

Builds a ClearCommand

Specified by:

buildClearCommand in interface CommandsFactory

Parameters:

flags - Command flags provided by cache

Returns:

a ClearCommand

buildEvictCommand

public EvictCommand buildEvictCommand(Object key,
                                      Set<Flag> flags)

Description copied from interface: CommandsFactory

Builds an EvictCommand

Specified by:

buildEvictCommand in interface CommandsFactory

Parameters:

key - key to evict

flags - Command flags provided by cache

Returns:

an EvictCommand

buildPrepareCommand

public PrepareCommand buildPrepareCommand(GlobalTransaction gtx,
                                          List<WriteCommand> modifications,
                                          boolean onePhaseCommit)

Description copied from interface: CommandsFactory

Builds a PrepareCommand

Specified by:

buildPrepareCommand in interface CommandsFactory

Parameters:

gtx - global transaction associated with the prepare

modifications - list of modifications

onePhaseCommit - is this a one-phase or two-phase transaction?

Returns:

a PrepareCommand

buildVersionedPrepareCommand

public VersionedPrepareCommand buildVersionedPrepareCommand(GlobalTransaction gtx,
                                                            List<WriteCommand> modifications,
                                                            boolean onePhase)

Description copied from interface: CommandsFactory

Builds a VersionedPrepareCommand

Specified by:

buildVersionedPrepareCommand in interface CommandsFactory

Parameters:

gtx - global transaction associated with the prepare

modifications - list of modifications

Returns:

a VersionedPrepareCommand

buildCommitCommand

public CommitCommand buildCommitCommand(GlobalTransaction gtx)

Description copied from interface: CommandsFactory

Builds a CommitCommand

Specified by:

buildCommitCommand in interface CommandsFactory

Parameters:

gtx - global transaction associated with the commit

Returns:

a CommitCommand

buildVersionedCommitCommand

public VersionedCommitCommand buildVersionedCommitCommand(GlobalTransaction gtx)

Description copied from interface: CommandsFactory

Builds a VersionedCommitCommand

Specified by:

buildVersionedCommitCommand in interface CommandsFactory

Parameters:

gtx - global transaction associated with the commit

Returns:

a VersionedCommitCommand

buildRollbackCommand

public RollbackCommand buildRollbackCommand(GlobalTransaction gtx)

Description copied from interface: CommandsFactory

Builds a RollbackCommand

Specified by:

buildRollbackCommand in interface CommandsFactory

Parameters:

gtx - global transaction associated with the rollback

Returns:

a RollbackCommand

buildReplicateCommand

public MultipleRpcCommand buildReplicateCommand(List<ReplicableCommand> toReplicate)

Description copied from interface: CommandsFactory

Builds an RpcCommand "envelope" containing multiple ReplicableCommands

Specified by:

buildReplicateCommand in interface CommandsFactory

Parameters:

toReplicate - ReplicableCommands to include in the envelope

Returns:

a MultipleRpcCommand

buildSingleRpcCommand

public SingleRpcCommand buildSingleRpcCommand(ReplicableCommand call)

Description copied from interface: CommandsFactory

Builds a SingleRpcCommand "envelope" containing a single ReplicableCommand

Specified by:

buildSingleRpcCommand in interface CommandsFactory

Parameters:

call - ReplicableCommand to include in the envelope

Returns:

a SingleRpcCommand

buildClusteredGetCommand

public ClusteredGetCommand buildClusteredGetCommand(Object key,
                                                    Set<Flag> flags,
                                                    boolean acquireRemoteLock,
                                                    GlobalTransaction gtx)

Description copied from interface: CommandsFactory

Builds a ClusteredGetCommand, which is a remote lookup command

Specified by:

buildClusteredGetCommand in interface CommandsFactory

Parameters:

key - key to look up

Returns:

a ClusteredGetCommand

initializeReplicableCommand

public void initializeReplicableCommand(ReplicableCommand c,
                                        boolean isRemote)

Description copied from interface: CommandsFactory

Initializes a ReplicableCommand read from a data stream with components specific to the target cache instance.

Implementations should also be deep, in that if the command contains other commands, these should be recursed into.

Specified by:

initializeReplicableCommand in interface CommandsFactory

Parameters:

isRemote - true if the command is deserialized and is executed remote.

c - command to initialize. Cannot be null.

buildLockControlCommand

public LockControlCommand buildLockControlCommand(Collection<?> keys,
                                                  Set<Flag> flags,
                                                  GlobalTransaction gtx)

Description copied from interface: CommandsFactory

Builds a LockControlCommand to control explicit remote locking

Specified by:

buildLockControlCommand in interface CommandsFactory

Parameters:

keys - keys to lock

Returns:

a LockControlCommand

buildLockControlCommand

public LockControlCommand buildLockControlCommand(Object key,
                                                  Set<Flag> flags,
                                                  GlobalTransaction gtx)

Description copied from interface: CommandsFactory

Same as CommandsFactory.buildLockControlCommand(Object, java.util.Set, org.infinispan.transaction.xa.GlobalTransaction) but for locking a single key vs a collection of keys.

Specified by:

buildLockControlCommand in interface CommandsFactory

buildLockControlCommand

public LockControlCommand buildLockControlCommand(Collection<?> keys,
                                                  Set<Flag> flags)

Specified by:

buildLockControlCommand in interface CommandsFactory

buildStateRequestCommand

public StateRequestCommand buildStateRequestCommand(StateRequestCommand.Type subtype,
                                                    Address sender,
                                                    int viewId,
                                                    Set<Integer> segments)

Description copied from interface: CommandsFactory

Builds a StateRequestCommand used for requesting transactions and locks and for starting or canceling transfer of cache entries.

Specified by:

buildStateRequestCommand in interface CommandsFactory

buildStateResponseCommand

public StateResponseCommand buildStateResponseCommand(Address sender,
                                                      int topologyId,
                                                      Collection<StateChunk> stateChunks)

Description copied from interface: CommandsFactory

Builds a StateResponseCommand used for pushing cache entries to another node in response to a StateRequestCommand.

Specified by:

buildStateResponseCommand in interface CommandsFactory

getCacheName

public String getCacheName()

Description copied from interface: CommandsFactory

Retrieves the cache name this CommandFactory is set up to construct commands for.

Specified by:

getCacheName in interface CommandsFactory

Returns:

the name of the cache this CommandFactory is set up to construct commands for.

buildGetInDoubtTransactionsCommand

public GetInDoubtTransactionsCommand buildGetInDoubtTransactionsCommand()

Description copied from interface: CommandsFactory

Builds a GetInDoubtTransactionsCommand.

Specified by:

buildGetInDoubtTransactionsCommand in interface CommandsFactory

buildTxCompletionNotificationCommand

public TxCompletionNotificationCommand buildTxCompletionNotificationCommand(Xid xid,
                                                                            GlobalTransaction globalTransaction)

Description copied from interface: CommandsFactory

Builds a TxCompletionNotificationCommand.

Specified by:

buildTxCompletionNotificationCommand in interface CommandsFactory

buildTxCompletionNotificationCommand

public TxCompletionNotificationCommand buildTxCompletionNotificationCommand(long internalId)

Specified by:

buildTxCompletionNotificationCommand in interface CommandsFactory

Parameters:

internalId - the internal id identifying the transaction to be removed.

See Also:

TxCompletionNotificationCommand

buildDistributedExecuteCommand

public <T> DistributedExecuteCommand<T> buildDistributedExecuteCommand(Callable<T> callable,
                                                                       Address sender,
                                                                       Collection keys)

Description copied from interface: CommandsFactory

Builds a DistributedExecuteCommand used for migration and execution of distributed Callables and Runnables.

Specified by:

buildDistributedExecuteCommand in interface CommandsFactory

Parameters:

callable - the callable task

sender - sender's Address

keys - keys used in Callable

Returns:

a DistributedExecuteCommand

buildMapCombineCommand

public <KIn,VIn,KOut,VOut> MapCombineCommand<KIn,VIn,KOut,VOut> buildMapCombineCommand(String taskId,
                                                                                       Mapper<KIn,VIn,KOut,VOut> m,
                                                                                       Reducer<KOut,VOut> r,
                                                                                       Collection<KIn> keys)

Description copied from interface: CommandsFactory

Builds a MapCombineCommand used for migration and map phase execution of MapReduce tasks.

Specified by:

buildMapCombineCommand in interface CommandsFactory

m - Mapper for MapReduceTask

r - Combiner for MapReduceTask

keys - keys used in MapReduceTask

Returns:

created MapCombineCommand

buildGetInDoubtTxInfoCommand

public GetInDoubtTxInfoCommand buildGetInDoubtTxInfoCommand()

Specified by:

buildGetInDoubtTxInfoCommand in interface CommandsFactory

See Also:

GetInDoubtTxInfoCommand

buildCompleteTransactionCommand

public CompleteTransactionCommand buildCompleteTransactionCommand(Xid xid,
                                                                  boolean commit)

Description copied from interface: CommandsFactory

Builds a CompleteTransactionCommand command.

Specified by:

buildCompleteTransactionCommand in interface CommandsFactory

Parameters:

xid - the xid identifying the transaction we want to complete.

commit - commit(true) or rollback(false)?

buildApplyDeltaCommand

public ApplyDeltaCommand buildApplyDeltaCommand(Object deltaAwareValueKey,
                                                Delta delta,
                                                Collection keys)

Description copied from interface: CommandsFactory

Builds a ApplyDeltaCommand used for applying Delta objects to DeltaAware containers stored in cache

Specified by:

buildApplyDeltaCommand in interface CommandsFactory

Returns:

ApplyDeltaCommand instance

See Also:

ApplyDeltaCommand

buildCreateCacheCommand

public CreateCacheCommand buildCreateCacheCommand(String cacheNameToCreate,
                                                  String cacheConfigurationName)

Description copied from interface: CommandsFactory

Same as buildCreateCacheCommand(cacheName, cacheConfigurationName, false, 0).

Specified by:

buildCreateCacheCommand in interface CommandsFactory

buildCreateCacheCommand

public CreateCacheCommand buildCreateCacheCommand(String cacheNameToCreate,
                                                  String cacheConfigurationName,
                                                  int size)

Description copied from interface: CommandsFactory

Builds a CreateCacheCommand used to create/start cache around Infinispan cluster

Specified by:

buildCreateCacheCommand in interface CommandsFactory

size - If size > 0, the command will wait until the cache runs on at least size nodes.

buildReduceCommand

public <KOut,VOut> ReduceCommand<KOut,VOut> buildReduceCommand(String taskId,
                                                               String destintationCache,
                                                               Reducer<KOut,VOut> r,
                                                               Collection<KOut> keys)

Description copied from interface: CommandsFactory

Builds a ReduceCommand used for migration and reduce phase execution of MapReduce tasks.

Specified by:

buildReduceCommand in interface CommandsFactory

r - Reducer for MapReduceTask

keys - keys used in MapReduceTask

Returns:

created ReduceCommand

buildCancelCommandCommand

public CancelCommand buildCancelCommandCommand(UUID commandUUID)

Description copied from interface: CommandsFactory

Builds CancelCommandCommand used to cancel other commands executing on Infinispan cluster

Specified by:

buildCancelCommandCommand in interface CommandsFactory

Parameters:

commandUUID - UUID for command to cancel

Returns:

created CancelCommandCommand

buildXSiteStateTransferControlCommand

public XSiteStateTransferControlCommand buildXSiteStateTransferControlCommand(XSiteStateTransferControlCommand.StateTransferControl control,
                                                                              String siteName)

Description copied from interface: CommandsFactory

Builds XSiteStateTransferControlCommand used to control the-cross site state transfer.

Specified by:

buildXSiteStateTransferControlCommand in interface CommandsFactory

Parameters:

control - the control operation

siteName - the site name, needed for some control operations.

Returns:

the XSiteStateTransferControlCommand created

buildXSiteAdminCommand

public XSiteAdminCommand buildXSiteAdminCommand(String siteName,
                                                XSiteAdminCommand.AdminOperation op,
                                                Integer afterFailures,
                                                Long minTimeToWait)

Description copied from interface: CommandsFactory

Builds XSiteAdminCommand used to perform system administrator operations.

Specified by:

buildXSiteAdminCommand in interface CommandsFactory

Returns:

the XSiteAdminCommand created

buildXSiteStatePushCommand

public XSiteStatePushCommand buildXSiteStatePushCommand(XSiteState[] chunk,
                                                        long timeoutMillis)

Description copied from interface: CommandsFactory

Builds XSiteStatePushCommand used to transfer a single chunk of data between sites.

Specified by:

buildXSiteStatePushCommand in interface CommandsFactory

Parameters:

chunk - the data chunk

timeoutMillis - timeout in milliseconds, for the retries in the receiver site.

Returns:

the XSiteStatePushCommand created

buildSingleXSiteRpcCommand

public SingleXSiteRpcCommand buildSingleXSiteRpcCommand(VisitableCommand command)

Description copied from interface: CommandsFactory

Builds SingleRpcCommand used to perform VisitableCommand on the backup site,

Specified by:

buildSingleXSiteRpcCommand in interface CommandsFactory

Parameters:

command - the visitable command.

Returns:

the SingleXSiteRpcCommand created

buildEntryRequestCommand

public <K,V,C> EntryRequestCommand<K,V,C> buildEntryRequestCommand(UUID identifier,
                                                                   Set<Integer> segments,
                                                                   Set<K> keysToFilter,
                                                                   KeyValueFilter<? super K,? super V> filter,
                                                                   Converter<? super K,? super V,C> converter,
                                                                   Set<Flag> flags)

Description copied from interface: CommandsFactory

Builds EntryRequestCommand used to request entries from a remote node for given segments

Specified by:

buildEntryRequestCommand in interface CommandsFactory

Type Parameters:

K - The key type of the stored key

V - The value type of the stored values

C - The converted type after the value is applied from the converter

Parameters:

identifier - The unique identifier for this entry retrieval request

segments - The segments this request should retrieve

filter - The filter to apply to any found values to limit response data

converter - The converter to apply to any found values

flags - The flags used to modify behavior

Returns:

the EntryRequestCommand created

buildEntryResponseCommand

public <K,C> EntryResponseCommand<K,C> buildEntryResponseCommand(UUID identifier,
                                                                 Set<Integer> completedSegments,
                                                                 Set<Integer> inDoubtSegments,
                                                                 Collection<CacheEntry<K,C>> values,
                                                                 CacheException e)

Description copied from interface: CommandsFactory

Builds EntryResponseCommand use to respond with retrieved entries for given segments

Specified by:

buildEntryResponseCommand in interface CommandsFactory

Type Parameters:

K - The key type of the stored key

C - The converted type after the value is applied from the converter

Parameters:

identifier - The unique identifier for this entry retrieval request

completedSegments - The segments that are now completed per this response

inDoubtSegments - The segements that are now in doubt meaning they must be retrieved again from another node due to rehash

values - The entries retrieved from the remote node

e - If an exception occurred while running the processing on the remote node

Returns:

The EntryResponseCommand created

buildGetKeysInGroupCommand

public GetKeysInGroupCommand buildGetKeysInGroupCommand(Set<Flag> flags,
                                                        String groupName)

Description copied from interface: CommandsFactory

Builds GetKeysInGroupCommand used to fetch all the keys belonging to a group.

Specified by:

buildGetKeysInGroupCommand in interface CommandsFactory

groupName - the group name.

Returns:

the GetKeysInGroup created.

buildStreamRequestCommand

public <K> StreamRequestCommand<K> buildStreamRequestCommand(Object id,
                                                             boolean parallelStream,
                                                             StreamRequestCommand.Type type,
                                                             Set<Integer> segments,
                                                             Set<K> keys,
                                                             Set<K> excludedKeys,
                                                             boolean includeLoader,
                                                             Object terminalOperation)

Specified by:

buildStreamRequestCommand in interface CommandsFactory

buildStreamResponseCommand

public <R> StreamResponseCommand<R> buildStreamResponseCommand(Object identifier,
                                                               boolean complete,
                                                               Set<Integer> lostSegments,
                                                               R response)

Description copied from interface: CommandsFactory

Builds StreamResponseCommand used to send back a response either intermediate or complete to the originating node with the information for the stream request.

Specified by:

buildStreamResponseCommand in interface CommandsFactory

Type Parameters:

R - type of response

Parameters:

identifier - the unique identifier for the stream request

complete - whether or not this is an intermediate or final response from this node for the given id

lostSegments - what segments that were lost during processing

response - the actual response

Returns:

the command to send back the response

buildGetCacheEntryCommand

public GetCacheEntryCommand buildGetCacheEntryCommand(Object key,
                                                      Set<Flag> explicitFlags)

Description copied from interface: CommandsFactory

Builds a GetCacheEntryCommand

Specified by:

buildGetCacheEntryCommand in interface CommandsFactory

Parameters:

key - key to get

explicitFlags - Command flags provided by cache

Returns:

a GetCacheEntryCommand

buildClusteredGetAllCommand

public ClusteredGetAllCommand buildClusteredGetAllCommand(List<?> keys,
                                                          Set<Flag> flags,
                                                          GlobalTransaction gtx)

Description copied from interface: CommandsFactory

Builds a ClusteredGetAllCommand, which is a remote lookup command

Specified by:

buildClusteredGetAllCommand in interface CommandsFactory

Parameters:

keys - key to look up

Returns:

a ClusteredGetAllCommand

buildReadOnlyKeyCommand

public <K,V,R> ReadOnlyKeyCommand<K,V,R> buildReadOnlyKeyCommand(K key,
                                                                 Function<EntryView.ReadEntryView<K,V>,R> f)

Specified by:

buildReadOnlyKeyCommand in interface CommandsFactory

buildReadOnlyManyCommand

public <K,V,R> ReadOnlyManyCommand<K,V,R> buildReadOnlyManyCommand(Set<? extends K> keys,
                                                                   Function<EntryView.ReadEntryView<K,V>,R> f)

Specified by:

buildReadOnlyManyCommand in interface CommandsFactory

buildReadWriteKeyValueCommand

public <K,V,R> ReadWriteKeyValueCommand<K,V,R> buildReadWriteKeyValueCommand(K key,
                                                                             V value,
                                                                             BiFunction<V,EntryView.ReadWriteEntryView<K,V>,R> f,
                                                                             Params params)

Specified by:

buildReadWriteKeyValueCommand in interface CommandsFactory

buildReadWriteKeyCommand

public <K,V,R> ReadWriteKeyCommand<K,V,R> buildReadWriteKeyCommand(K key,
                                                                   Function<EntryView.ReadWriteEntryView<K,V>,R> f,
                                                                   Params params)

Specified by:

buildReadWriteKeyCommand in interface CommandsFactory

buildReadWriteManyCommand

public <K,V,R> ReadWriteManyCommand<K,V,R> buildReadWriteManyCommand(Set<? extends K> keys,
                                                                     Function<EntryView.ReadWriteEntryView<K,V>,R> f,
                                                                     Params params)

Specified by:

buildReadWriteManyCommand in interface CommandsFactory

buildReadWriteManyEntriesCommand

public <K,V,R> ReadWriteManyEntriesCommand<K,V,R> buildReadWriteManyEntriesCommand(Map<? extends K,? extends V> entries,
                                                                                   BiFunction<V,EntryView.ReadWriteEntryView<K,V>,R> f,
                                                                                   Params params)

Specified by:

buildReadWriteManyEntriesCommand in interface CommandsFactory

buildWriteOnlyKeyCommand

public <K,V> WriteOnlyKeyCommand<K,V> buildWriteOnlyKeyCommand(K key,
                                                               Consumer<EntryView.WriteEntryView<V>> f,
                                                               Params params)

Specified by:

buildWriteOnlyKeyCommand in interface CommandsFactory

buildWriteOnlyKeyValueCommand

public <K,V> WriteOnlyKeyValueCommand<K,V> buildWriteOnlyKeyValueCommand(K key,
                                                                         V value,
                                                                         BiConsumer<V,EntryView.WriteEntryView<V>> f,
                                                                         Params params)

Specified by:

buildWriteOnlyKeyValueCommand in interface CommandsFactory

buildWriteOnlyManyCommand

public <K,V> WriteOnlyManyCommand<K,V> buildWriteOnlyManyCommand(Set<? extends K> keys,
                                                                 Consumer<EntryView.WriteEntryView<V>> f,
                                                                 Params params)

Specified by:

buildWriteOnlyManyCommand in interface CommandsFactory

buildWriteOnlyManyEntriesCommand

public <K,V> WriteOnlyManyEntriesCommand<K,V> buildWriteOnlyManyEntriesCommand(Map<? extends K,? extends V> entries,
                                                                               BiConsumer<V,EntryView.WriteEntryView<V>> f,
                                                                               Params params)

Specified by:

buildWriteOnlyManyEntriesCommand in interface CommandsFactory