CommandsFactoryImpl (Red Hat JBoss Enterprise Application Platform 7.4.7.GA public API)

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 <sanne@hibernate.org> (C) 2011 Red Hat Inc.

Constructor Summary

Constructors
Constructor and Description

CommandsFactoryImpl()

Constructors
Constructor and Description
`CommandsFactoryImpl()`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`BackupAckCommand`	`buildBackupAckCommand(long id, int topologyId)`
`BackupMultiKeyAckCommand`	`buildBackupMultiKeyAckCommand(long id, int segment, int topologyId)`
`CancelPublisherCommand`	`buildCancelPublisherCommand(String requestId)`
`CheckTransactionRpcCommand`	`buildCheckTransactionRpcCommand(Collection<GlobalTransaction> globalTransactions)`
`ClearCommand`	`buildClearCommand(long flagsBitSet)` Builds a ClearCommand
`ClusteredGetAllCommand`	`buildClusteredGetAllCommand(List<?> keys, long flagsBitSet, GlobalTransaction gtx)` Builds a ClusteredGetAllCommand, which is a remote lookup command
`ClusteredGetCommand`	`buildClusteredGetCommand(Object key, int segment, long flagsBitSet)` Builds a ClusteredGetCommand, which is a remote lookup command
`CommitCommand`	`buildCommitCommand(GlobalTransaction gtx)` Builds a CommitCommand
`CompleteTransactionCommand`	`buildCompleteTransactionCommand(XidImpl xid, boolean commit)` Builds a CompleteTransactionCommand command.
`ComputeCommand`	`buildComputeCommand(Object key, BiFunction mappingFunction, boolean computeIfPresent, int segment, Metadata metadata, long flagsBitSet)` Builds a ComputeCommand
`ComputeIfAbsentCommand`	`buildComputeIfAbsentCommand(Object key, Function mappingFunction, int segment, Metadata metadata, long flagsBitSet)` Builds a ComputeIfAbsentCommand
`ConflictResolutionStartCommand`	`buildConflictResolutionStartCommand(int topologyId, IntSet segments)`
`<K,V,R> ReductionPublisherRequestCommand<K>`	`buildEntryReductionPublisherCommand(boolean parallelStream, DeliveryGuarantee deliveryGuarantee, IntSet segments, Set<K> keys, Set<K> excludedKeys, boolean includeLoader, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)`
`EntrySetCommand`	`buildEntrySetCommand(long flagsBitSet)` Builds a EntrySetCommand
`EvictCommand`	`buildEvictCommand(Object key, int segment, long flagsBitSet)` Builds an EvictCommand
`ExceptionAckCommand`	`buildExceptionAckCommand(long id, Throwable throwable, int topologyId)`
`GetAllCommand`	`buildGetAllCommand(Collection<?> keys, long flagsBitSet, boolean returnEntries)` Builds a GetAllCommand
`GetCacheEntryCommand`	`buildGetCacheEntryCommand(Object key, int segment, long flagsBitSet)` Builds a GetCacheEntryCommand
`GetInDoubtTransactionsCommand`	`buildGetInDoubtTransactionsCommand()` Builds a `GetInDoubtTransactionsCommand`.
`GetInDoubtTxInfoCommand`	`buildGetInDoubtTxInfoCommand()`
`GetKeysInGroupCommand`	`buildGetKeysInGroupCommand(long flagsBitSet, Object groupName)` Builds `GetKeysInGroupCommand` used to fetch all the keys belonging to a group.
`GetKeyValueCommand`	`buildGetKeyValueCommand(Object key, int segment, long flagsBitSet)` Builds a GetKeyValueCommand
`<K,I,R> InitialPublisherCommand<K,I,R>`	`buildInitialPublisherCommand(String requestId, DeliveryGuarantee deliveryGuarantee, int batchSize, IntSet segments, Set<K> keys, Set<K> excludedKeys, boolean includeLoader, boolean entryStream, boolean trackKeys, Function<? super org.reactivestreams.Publisher<I>,? extends org.reactivestreams.Publisher<R>> transformer)`
`InvalidateCommand`	`buildInvalidateCommand(long flagsBitSet, Object... keys)` Builds an InvalidateCommand
`InvalidateCommand`	`buildInvalidateFromL1Command(Address origin, long flagsBitSet, Collection<Object> keys)`
`InvalidateCommand`	`buildInvalidateFromL1Command(long flagsBitSet, Collection<Object> keys)` Builds an InvalidateFromL1Command
`InvalidateVersionsCommand`	`buildInvalidateVersionsCommand(int topologyId, Object[] keys, int[] topologyIds, long[] versions, boolean removed)`
`IracCleanupKeyCommand`	`buildIracCleanupKeyCommand(Object key, Object lockOwner, IracMetadata tombstone)`
`IracClearKeysCommand`	`buildIracClearKeysCommand()`
`IracMetadataRequestCommand`	`buildIracMetadataRequestCommand(int segment)`
`<K,V> IracPutKeyCommand`	`buildIracPutKeyCommand(InternalCacheEntry<K,V> entry)`
`IracRemoveKeyCommand`	`buildIracRemoveKeyCommand(Object key, IracMetadata iracMetadata)`
`IracRequestStateCommand`	`buildIracRequestStateCommand(IntSet segments)`
`IracStateResponseCommand`	`buildIracStateResponseCommand(Object key, Object lockOwner, IracMetadata tombstone)`
`<K,R> ReductionPublisherRequestCommand<K>`	`buildKeyReductionPublisherCommand(boolean parallelStream, DeliveryGuarantee deliveryGuarantee, IntSet segments, Set<K> keys, Set<K> excludedKeys, boolean includeLoader, Function<? super org.reactivestreams.Publisher<K>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)`
`KeySetCommand`	`buildKeySetCommand(long flagsBitSet)` Builds a KeySetCommand
`LockControlCommand`	`buildLockControlCommand(Collection<?> keys, long flagsBitSet)`
`LockControlCommand`	`buildLockControlCommand(Collection<?> keys, long flagsBitSet, GlobalTransaction gtx)` Builds a LockControlCommand to control explicit remote locking
`LockControlCommand`	`buildLockControlCommand(Object key, long flagsBitSet, GlobalTransaction gtx)` Same as `CommandsFactory.buildLockControlCommand(Object, long, GlobalTransaction)` but for locking a single key vs a collection of keys.
`<K,V> MultiClusterEventCommand<K,V>`	`buildMultiClusterEventCommand(Map<UUID,Collection<ClusterEvent<K,V>>> events)`
`MultiEntriesFunctionalBackupWriteCommand`	`buildMultiEntriesFunctionalBackupWriteCommand()`
`MultiKeyFunctionalBackupWriteCommand`	`buildMultiKeyFunctionalBackupWriteCommand()`
`NextPublisherCommand`	`buildNextPublisherCommand(String requestId)`
`PrepareCommand`	`buildPrepareCommand(GlobalTransaction gtx, List<WriteCommand> modifications, boolean onePhaseCommit)` Builds a PrepareCommand
`PutKeyValueCommand`	`buildPutKeyValueCommand(Object key, Object value, int segment, Metadata metadata, long flagsBitSet)` Builds a PutKeyValueCommand
`PutMapBackupWriteCommand`	`buildPutMapBackupWriteCommand()`
`PutMapCommand`	`buildPutMapCommand(Map<?,?> map, Metadata metadata, long flagsBitSet)` Builds a PutMapCommand
`<K,V,R> ReadOnlyKeyCommand<K,V,R>`	`buildReadOnlyKeyCommand(Object key, Function<EntryView.ReadEntryView<K,V>,R> f, int segment, Params params, DataConversion keyDataConversion, DataConversion valueDataConversion)`
`<K,V,R> ReadOnlyManyCommand<K,V,R>`	`buildReadOnlyManyCommand(Collection<?> keys, Function<EntryView.ReadEntryView<K,V>,R> f, Params params, DataConversion keyDataConversion, DataConversion valueDataConversion)`
`<K,V,R> ReadWriteKeyCommand<K,V,R>`	`buildReadWriteKeyCommand(Object key, Function<EntryView.ReadWriteEntryView<K,V>,R> f, int segment, Params params, DataConversion keyDataConversion, DataConversion valueDataConversion)`
`<K,V,T,R> ReadWriteKeyValueCommand<K,V,T,R>`	`buildReadWriteKeyValueCommand(Object key, Object argument, BiFunction<T,EntryView.ReadWriteEntryView<K,V>,R> f, int segment, Params params, DataConversion keyDataConversion, DataConversion valueDataConversion)`
`<K,V,R> ReadWriteManyCommand<K,V,R>`	`buildReadWriteManyCommand(Collection<?> keys, Function<EntryView.ReadWriteEntryView<K,V>,R> f, Params params, DataConversion keyDataConversion, DataConversion valueDataConversion)`
`<K,V,T,R> ReadWriteManyEntriesCommand<K,V,T,R>`	`buildReadWriteManyEntriesCommand(Map<?,?> entries, BiFunction<T,EntryView.ReadWriteEntryView<K,V>,R> f, Params params, DataConversion keyDataConversion, DataConversion valueDataConversion)`
`RemoveCommand`	`buildRemoveCommand(Object key, Object value, int segment, long flagsBitSet)` Builds a RemoveCommand
`RemoveExpiredCommand`	`buildRemoveExpiredCommand(Object key, Object value, int segment, long flagsBitSet)` Builds an expired remove command that is used to remove only a specific entry when it expires via maxIdle
`RemoveExpiredCommand`	`buildRemoveExpiredCommand(Object key, Object value, int segment, Long lifespan, long flagsBitSet)` Builds an expired remove command that is used to remove only a specific entry when it expires via lifespan
`RenewBiasCommand`	`buildRenewBiasCommand(Object[] keys)`
`ReplaceCommand`	`buildReplaceCommand(Object key, Object oldValue, Object newValue, int segment, Metadata metadata, long flagsBitSet)` Builds a ReplaceCommand
`RevokeBiasCommand`	`buildRevokeBiasCommand(Address ackTarget, long id, int topologyId, Collection<Object> keys)`
`RollbackCommand`	`buildRollbackCommand(GlobalTransaction gtx)` Builds a RollbackCommand
`ScatteredStateConfirmRevokedCommand`	`buildScatteredStateConfirmRevokeCommand(int topologyId, IntSet segments)`
`ScatteredStateGetKeysCommand`	`buildScatteredStateGetKeysCommand(int topologyId, IntSet segments)`
`SingleKeyBackupWriteCommand`	`buildSingleKeyBackupWriteCommand()`
`SingleKeyFunctionalBackupWriteCommand`	`buildSingleKeyFunctionalBackupWriteCommand()`
`SingleRpcCommand`	`buildSingleRpcCommand(VisitableCommand 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(long flagsBitSet)` Builds a SizeCommand
`StateResponseCommand`	`buildStateResponseCommand(int topologyId, Collection<StateChunk> stateChunks, boolean applyState, boolean pushTransfer)` Builds a StateResponseCommand used for pushing cache entries to another node.
`StateTransferCancelCommand`	`buildStateTransferCancelCommand(int topologyId, IntSet segments)`
`StateTransferGetListenersCommand`	`buildStateTransferGetListenersCommand(int topologyId)`
`StateTransferGetTransactionsCommand`	`buildStateTransferGetTransactionsCommand(int topologyId, IntSet segments)`
`StateTransferStartCommand`	`buildStateTransferStartCommand(int topologyId, IntSet segments)`
`TouchCommand`	`buildTouchCommand(Object key, int segment)`
`TxCompletionNotificationCommand`	`buildTxCompletionNotificationCommand(long internalId)`
`TxCompletionNotificationCommand`	`buildTxCompletionNotificationCommand(XidImpl xid, GlobalTransaction globalTransaction)` Builds a `TxCompletionNotificationCommand`.
`<K,V,R> TxReadOnlyKeyCommand<K,V,R>`	`buildTxReadOnlyKeyCommand(Object key, Function<EntryView.ReadEntryView<K,V>,R> f, List<Mutation<K,V,?>> mutations, int segment, Params params, DataConversion keyDataConversion, DataConversion valueDataConversion)`
`<K,V,R> TxReadOnlyManyCommand<K,V,R>`	`buildTxReadOnlyManyCommand(Collection<?> keys, List<List<Mutation<K,V,?>>> mutations, Params params, DataConversion keyDataConversion, DataConversion valueDataConversion)`
`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(Object key, Consumer<EntryView.WriteEntryView<K,V>> f, int segment, Params params, DataConversion keyDataConversion, DataConversion valueDataConversion)`
`<K,V,T> WriteOnlyKeyValueCommand<K,V,T>`	`buildWriteOnlyKeyValueCommand(Object key, Object argument, BiConsumer<T,EntryView.WriteEntryView<K,V>> f, int segment, Params params, DataConversion keyDataConversion, DataConversion valueDataConversion)`
`<K,V> WriteOnlyManyCommand<K,V>`	`buildWriteOnlyManyCommand(Collection<?> keys, Consumer<EntryView.WriteEntryView<K,V>> f, Params params, DataConversion keyDataConversion, DataConversion valueDataConversion)`
`<K,V,T> WriteOnlyManyEntriesCommand<K,V,T>`	`buildWriteOnlyManyEntriesCommand(Map<?,?> arguments, BiConsumer<T,EntryView.WriteEntryView<K,V>> f, Params params, DataConversion keyDataConversion, DataConversion valueDataConversion)`
`XSiteAmendOfflineStatusCommand`	`buildXSiteAmendOfflineStatusCommand(String siteName, Integer afterFailures, Long minTimeToWait)`
`XSiteBringOnlineCommand`	`buildXSiteBringOnlineCommand(String siteName)`
`XSiteOfflineStatusCommand`	`buildXSiteOfflineStatusCommand(String siteName)`
`XSiteStatePushCommand`	`buildXSiteStatePushCommand(XSiteState[] chunk, long timeoutMillis)` Builds XSiteStatePushCommand used to transfer a single chunk of data between sites.
`XSiteStateTransferCancelSendCommand`	`buildXSiteStateTransferCancelSendCommand(String siteName)`
`XSiteStateTransferClearStatusCommand`	`buildXSiteStateTransferClearStatusCommand()`
`XSiteStateTransferFinishReceiveCommand`	`buildXSiteStateTransferFinishReceiveCommand(String siteName)`
`XSiteStateTransferFinishSendCommand`	`buildXSiteStateTransferFinishSendCommand(String siteName, boolean statusOk)`
`XSiteStateTransferRestartSendingCommand`	`buildXSiteStateTransferRestartSendingCommand(String siteName, int topologyId)`
`XSiteStateTransferStartReceiveCommand`	`buildXSiteStateTransferStartReceiveCommand(String siteName)`
`XSiteStateTransferStartSendCommand`	`buildXSiteStateTransferStartSendCommand(String siteName, int topologyId)`
`XSiteStateTransferStatusRequestCommand`	`buildXSiteStateTransferStatusRequestCommand()`
`XSiteStatusCommand`	`buildXSiteStatusCommand()`
`XSiteTakeOfflineCommand`	`buildXSiteTakeOfflineCommand(String siteName)`
`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`	`start()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.infinispan.commands.CommandsFactory
buildSingleRpcCommand

Constructor Detail
- CommandsFactoryImpl
```
public CommandsFactoryImpl()
```

Method Detail

start
```
public void start()
```

buildPutKeyValueCommand

public PutKeyValueCommand buildPutKeyValueCommand(Object key,
                                                  Object value,
                                                  int segment,
                                                  Metadata metadata,
                                                  long flagsBitSet)

Description copied from interface: CommandsFactory

Builds a PutKeyValueCommand

Specified by:: buildPutKeyValueCommand in interface CommandsFactory
Parameters:: key - key to put; value - value to put; segment - the segment of the given key; metadata - metadata of entry; flagsBitSet - Command flags provided by cache
Returns:: a PutKeyValueCommand

buildRemoveCommand
```
public RemoveCommand buildRemoveCommand(Object key,
                                        Object value,
                                        int segment,
                                        long flagsBitSet)
```
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.

segment - the segment of the given key

flagsBitSet - Command flags provided by cache

Returns:

a RemoveCommand

buildInvalidateCommand
```
public InvalidateCommand buildInvalidateCommand(long flagsBitSet,
                                                Object... keys)
```
Description copied from interface: CommandsFactory

Builds an InvalidateCommand

Specified by:

buildInvalidateCommand in interface CommandsFactory

Parameters:

flagsBitSet - Command flags provided by cache

keys - keys to invalidate

Returns:

an InvalidateCommand

buildInvalidateFromL1Command
```
public InvalidateCommand buildInvalidateFromL1Command(long flagsBitSet,
                                                      Collection<Object> keys)
```
Description copied from interface: CommandsFactory

Builds an InvalidateFromL1Command

Specified by:

buildInvalidateFromL1Command in interface CommandsFactory

Parameters:

flagsBitSet - Command flags provided by cache

keys - keys to invalidate

Returns:

an InvalidateFromL1Command

buildInvalidateFromL1Command

public InvalidateCommand buildInvalidateFromL1Command(Address origin,
                                                      long flagsBitSet,
                                                      Collection<Object> keys)

Specified by:: buildInvalidateFromL1Command in interface CommandsFactory
See Also:: CommandsFactory.buildInvalidateFromL1Command(long, Collection)

buildRemoveExpiredCommand
```
public RemoveExpiredCommand buildRemoveExpiredCommand(Object key,
                                                      Object value,
                                                      int segment,
                                                      Long lifespan,
                                                      long flagsBitSet)
```
Description copied from interface: CommandsFactory

Builds an expired remove command that is used to remove only a specific entry when it expires via lifespan

Specified by:

buildRemoveExpiredCommand in interface CommandsFactory

Parameters:

key - the key of the expired entry

value - the value of the entry when it was expired

segment - the segment of the given key

lifespan - the lifespan that expired from the command

flagsBitSet - Command flags provided by cache

Returns:

a RemovedExpiredCommand

buildRemoveExpiredCommand
```
public RemoveExpiredCommand buildRemoveExpiredCommand(Object key,
                                                      Object value,
                                                      int segment,
                                                      long flagsBitSet)
```
Description copied from interface: CommandsFactory

Builds an expired remove command that is used to remove only a specific entry when it expires via maxIdle

Specified by:

buildRemoveExpiredCommand in interface CommandsFactory

Parameters:

key - the key of the expired entry

value - the value of the entry when it was expired

segment - the segment of the given key

flagsBitSet - Command flags provided by cache

Returns:

a RemovedExpiredCommand

buildReplaceCommand

public ReplaceCommand buildReplaceCommand(Object key,
                                          Object oldValue,
                                          Object newValue,
                                          int segment,
                                          Metadata metadata,
                                          long flagsBitSet)

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; segment - the segment of the given key; metadata - metadata of entry; flagsBitSet - Command flags provided by cache
Returns:: a ReplaceCommand

buildComputeCommand

public ComputeCommand buildComputeCommand(Object key,
                                          BiFunction mappingFunction,
                                          boolean computeIfPresent,
                                          int segment,
                                          Metadata metadata,
                                          long flagsBitSet)

Description copied from interface: CommandsFactory

Builds a ComputeCommand

Specified by:: buildComputeCommand in interface CommandsFactory
Parameters:: key - key to compute if this key is absent; mappingFunction - BiFunction for the key and the value; computeIfPresent - flag to apply as computeIfPresent mode; segment - the segment of the given key; metadata - metadata of entry; flagsBitSet - Command flags provided by cache
Returns:: a ComputeCommand

buildComputeIfAbsentCommand

public ComputeIfAbsentCommand buildComputeIfAbsentCommand(Object key,
                                                          Function mappingFunction,
                                                          int segment,
                                                          Metadata metadata,
                                                          long flagsBitSet)

Description copied from interface: CommandsFactory

Builds a ComputeIfAbsentCommand

Specified by:: buildComputeIfAbsentCommand in interface CommandsFactory
Parameters:: key - key to compute if this key is absent; mappingFunction - mappingFunction for the key; segment - the segment of the given key; metadata - metadata of entry; flagsBitSet - Command flags provided by cache
Returns:: a ComputeCommand

buildSizeCommand
```
public SizeCommand buildSizeCommand(long flagsBitSet)
```
Description copied from interface: CommandsFactory

Builds a SizeCommand

Specified by:

buildSizeCommand in interface CommandsFactory

Parameters:

flagsBitSet - Command flags provided by cache

Returns:

a SizeCommand

buildKeySetCommand
```
public KeySetCommand buildKeySetCommand(long flagsBitSet)
```
Description copied from interface: CommandsFactory

Builds a KeySetCommand

Specified by:

buildKeySetCommand in interface CommandsFactory

Parameters:

flagsBitSet - Command flags provided by cache

Returns:

a KeySetCommand

buildEntrySetCommand
```
public EntrySetCommand buildEntrySetCommand(long flagsBitSet)
```
Description copied from interface: CommandsFactory

Builds a EntrySetCommand

Specified by:

buildEntrySetCommand in interface CommandsFactory

Parameters:

flagsBitSet - Command flags provided by cache

Returns:

a EntrySetCommand

buildGetKeyValueCommand
```
public GetKeyValueCommand buildGetKeyValueCommand(Object key,
                                                  int segment,
                                                  long flagsBitSet)
```
Description copied from interface: CommandsFactory

Builds a GetKeyValueCommand

Specified by:

buildGetKeyValueCommand in interface CommandsFactory

Parameters:

key - key to get

segment - the segment of the given key

flagsBitSet - Command flags provided by cache

Returns:

a GetKeyValueCommand

buildGetAllCommand
```
public GetAllCommand buildGetAllCommand(Collection<?> keys,
                                        long flagsBitSet,
                                        boolean returnEntries)
```
Description copied from interface: CommandsFactory

Builds a GetAllCommand

Specified by:

buildGetAllCommand in interface CommandsFactory

Parameters:

keys - keys to get

flagsBitSet - 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,
                                        long flagsBitSet)
```
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

flagsBitSet - Command flags provided by cache

Returns:

a PutMapCommand

buildClearCommand
```
public ClearCommand buildClearCommand(long flagsBitSet)
```
Description copied from interface: CommandsFactory

Builds a ClearCommand

Specified by:

buildClearCommand in interface CommandsFactory

Parameters:

flagsBitSet - Command flags provided by cache

Returns:

a ClearCommand

buildEvictCommand
```
public EvictCommand buildEvictCommand(Object key,
                                      int segment,
                                      long flagsBitSet)
```
Description copied from interface: CommandsFactory

Builds an EvictCommand

Specified by:

buildEvictCommand in interface CommandsFactory

Parameters:

key - key to evict

segment - the segment for the key

flagsBitSet - 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

buildSingleRpcCommand
```
public SingleRpcCommand buildSingleRpcCommand(VisitableCommand call)
```
Description copied from interface: CommandsFactory

Builds a SingleRpcCommand "envelope" containing a single ReplicableCommand

Specified by:

buildSingleRpcCommand in interface CommandsFactory

Parameters:

call - VisitableCommand to include in the envelope

Returns:

a SingleRpcCommand

buildClusteredGetCommand
```
public ClusteredGetCommand buildClusteredGetCommand(Object key,
                                                    int segment,
                                                    long flagsBitSet)
```
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

segment - the segment for the key

flagsBitSet - Command flags provided by cache

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,
                                                  long flagsBitSet,
                                                  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

flagsBitSet - Command flags provided by cache

Returns:

a LockControlCommand

buildLockControlCommand
```
public LockControlCommand buildLockControlCommand(Object key,
                                                  long flagsBitSet,
                                                  GlobalTransaction gtx)
```
Description copied from interface: CommandsFactory

Same as CommandsFactory.buildLockControlCommand(Object, long, GlobalTransaction) but for locking a single key vs a collection of keys.

Specified by:

buildLockControlCommand in interface CommandsFactory

buildLockControlCommand

public LockControlCommand buildLockControlCommand(Collection<?> keys,
                                                  long flagsBitSet)

Specified by:: buildLockControlCommand in interface CommandsFactory

buildConflictResolutionStartCommand

public ConflictResolutionStartCommand buildConflictResolutionStartCommand(int topologyId,
                                                                          IntSet segments)

Specified by:: buildConflictResolutionStartCommand in interface CommandsFactory

buildScatteredStateConfirmRevokeCommand

public ScatteredStateConfirmRevokedCommand buildScatteredStateConfirmRevokeCommand(int topologyId,
                                                                                   IntSet segments)

Specified by:: buildScatteredStateConfirmRevokeCommand in interface CommandsFactory

buildScatteredStateGetKeysCommand

public ScatteredStateGetKeysCommand buildScatteredStateGetKeysCommand(int topologyId,
                                                                      IntSet segments)

Specified by:: buildScatteredStateGetKeysCommand in interface CommandsFactory

buildStateTransferCancelCommand

public StateTransferCancelCommand buildStateTransferCancelCommand(int topologyId,
                                                                  IntSet segments)

Specified by:: buildStateTransferCancelCommand in interface CommandsFactory

buildStateTransferGetListenersCommand
```
public StateTransferGetListenersCommand buildStateTransferGetListenersCommand(int topologyId)
```
Specified by:

buildStateTransferGetListenersCommand in interface CommandsFactory

buildStateTransferGetTransactionsCommand

public StateTransferGetTransactionsCommand buildStateTransferGetTransactionsCommand(int topologyId,
                                                                                    IntSet segments)

Specified by:: buildStateTransferGetTransactionsCommand in interface CommandsFactory

buildStateTransferStartCommand

public StateTransferStartCommand buildStateTransferStartCommand(int topologyId,
                                                                IntSet segments)

Specified by:: buildStateTransferStartCommand in interface CommandsFactory

buildStateResponseCommand

public StateResponseCommand buildStateResponseCommand(int topologyId,
                                                      Collection<StateChunk> stateChunks,
                                                      boolean applyState,
                                                      boolean pushTransfer)

Description copied from interface: CommandsFactory

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

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(XidImpl 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

buildGetInDoubtTxInfoCommand
```
public GetInDoubtTxInfoCommand buildGetInDoubtTxInfoCommand()
```
Specified by:

buildGetInDoubtTxInfoCommand in interface CommandsFactory

See Also:

GetInDoubtTxInfoCommand

buildCompleteTransactionCommand
```
public CompleteTransactionCommand buildCompleteTransactionCommand(XidImpl 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)?

buildXSiteStateTransferCancelSendCommand
```
public XSiteStateTransferCancelSendCommand buildXSiteStateTransferCancelSendCommand(String siteName)
```
Specified by:

buildXSiteStateTransferCancelSendCommand in interface CommandsFactory

buildXSiteStateTransferClearStatusCommand
```
public XSiteStateTransferClearStatusCommand buildXSiteStateTransferClearStatusCommand()
```
Specified by:

buildXSiteStateTransferClearStatusCommand in interface CommandsFactory

buildXSiteStateTransferFinishReceiveCommand
```
public XSiteStateTransferFinishReceiveCommand buildXSiteStateTransferFinishReceiveCommand(String siteName)
```
Specified by:

buildXSiteStateTransferFinishReceiveCommand in interface CommandsFactory

buildXSiteStateTransferFinishSendCommand

public XSiteStateTransferFinishSendCommand buildXSiteStateTransferFinishSendCommand(String siteName,
                                                                                    boolean statusOk)

Specified by:: buildXSiteStateTransferFinishSendCommand in interface CommandsFactory

buildXSiteStateTransferRestartSendingCommand

public XSiteStateTransferRestartSendingCommand buildXSiteStateTransferRestartSendingCommand(String siteName,
                                                                                            int topologyId)

Specified by:: buildXSiteStateTransferRestartSendingCommand in interface CommandsFactory

buildXSiteStateTransferStartReceiveCommand
```
public XSiteStateTransferStartReceiveCommand buildXSiteStateTransferStartReceiveCommand(String siteName)
```
Specified by:

buildXSiteStateTransferStartReceiveCommand in interface CommandsFactory

buildXSiteStateTransferStartSendCommand

public XSiteStateTransferStartSendCommand buildXSiteStateTransferStartSendCommand(String siteName,
                                                                                  int topologyId)

Specified by:: buildXSiteStateTransferStartSendCommand in interface CommandsFactory

buildXSiteStateTransferStatusRequestCommand
```
public XSiteStateTransferStatusRequestCommand buildXSiteStateTransferStatusRequestCommand()
```
Specified by:

buildXSiteStateTransferStatusRequestCommand in interface CommandsFactory

buildXSiteAmendOfflineStatusCommand

public XSiteAmendOfflineStatusCommand buildXSiteAmendOfflineStatusCommand(String siteName,
                                                                          Integer afterFailures,
                                                                          Long minTimeToWait)

Specified by:: buildXSiteAmendOfflineStatusCommand in interface CommandsFactory

buildXSiteBringOnlineCommand
```
public XSiteBringOnlineCommand buildXSiteBringOnlineCommand(String siteName)
```
Specified by:

buildXSiteBringOnlineCommand in interface CommandsFactory

buildXSiteOfflineStatusCommand
```
public XSiteOfflineStatusCommand buildXSiteOfflineStatusCommand(String siteName)
```
Specified by:

buildXSiteOfflineStatusCommand in interface CommandsFactory

buildXSiteStatusCommand
```
public XSiteStatusCommand buildXSiteStatusCommand()
```
Specified by:

buildXSiteStatusCommand in interface CommandsFactory

buildXSiteTakeOfflineCommand
```
public XSiteTakeOfflineCommand buildXSiteTakeOfflineCommand(String siteName)
```
Specified by:

buildXSiteTakeOfflineCommand in interface CommandsFactory

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

buildGetKeysInGroupCommand
```
public GetKeysInGroupCommand buildGetKeysInGroupCommand(long flagsBitSet,
                                                        Object groupName)
```
Description copied from interface: CommandsFactory

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

Specified by:

buildGetKeysInGroupCommand in interface CommandsFactory

Parameters:

flagsBitSet - Command flags provided by cache

groupName - the group name.

Returns:

the GetKeysInGroup created.

buildGetCacheEntryCommand
```
public GetCacheEntryCommand buildGetCacheEntryCommand(Object key,
                                                      int segment,
                                                      long flagsBitSet)
```
Description copied from interface: CommandsFactory

Builds a GetCacheEntryCommand

Specified by:

buildGetCacheEntryCommand in interface CommandsFactory

Parameters:

key - key to get

segment - the segment for the key

flagsBitSet - Command flags provided by cache

Returns:

a GetCacheEntryCommand

buildClusteredGetAllCommand
```
public ClusteredGetAllCommand buildClusteredGetAllCommand(List<?> keys,
                                                          long flagsBitSet,
                                                          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

flagsBitSet - Command flags provided by cache

Returns:

a ClusteredGetAllCommand

buildReadOnlyKeyCommand

public <K,V,R> ReadOnlyKeyCommand<K,V,R> buildReadOnlyKeyCommand(Object key,
                                                                 Function<EntryView.ReadEntryView<K,V>,R> f,
                                                                 int segment,
                                                                 Params params,
                                                                 DataConversion keyDataConversion,
                                                                 DataConversion valueDataConversion)

Specified by:: buildReadOnlyKeyCommand in interface CommandsFactory

buildReadOnlyManyCommand

public <K,V,R> ReadOnlyManyCommand<K,V,R> buildReadOnlyManyCommand(Collection<?> keys,
                                                                   Function<EntryView.ReadEntryView<K,V>,R> f,
                                                                   Params params,
                                                                   DataConversion keyDataConversion,
                                                                   DataConversion valueDataConversion)

Specified by:: buildReadOnlyManyCommand in interface CommandsFactory

buildReadWriteKeyValueCommand

public <K,V,T,R> ReadWriteKeyValueCommand<K,V,T,R> buildReadWriteKeyValueCommand(Object key,
                                                                                 Object argument,
                                                                                 BiFunction<T,EntryView.ReadWriteEntryView<K,V>,R> f,
                                                                                 int segment,
                                                                                 Params params,
                                                                                 DataConversion keyDataConversion,
                                                                                 DataConversion valueDataConversion)

Specified by:: buildReadWriteKeyValueCommand in interface CommandsFactory

buildReadWriteKeyCommand

public <K,V,R> ReadWriteKeyCommand<K,V,R> buildReadWriteKeyCommand(Object key,
                                                                   Function<EntryView.ReadWriteEntryView<K,V>,R> f,
                                                                   int segment,
                                                                   Params params,
                                                                   DataConversion keyDataConversion,
                                                                   DataConversion valueDataConversion)

Specified by:: buildReadWriteKeyCommand in interface CommandsFactory

buildReadWriteManyCommand

public <K,V,R> ReadWriteManyCommand<K,V,R> buildReadWriteManyCommand(Collection<?> keys,
                                                                     Function<EntryView.ReadWriteEntryView<K,V>,R> f,
                                                                     Params params,
                                                                     DataConversion keyDataConversion,
                                                                     DataConversion valueDataConversion)

Specified by:: buildReadWriteManyCommand in interface CommandsFactory

buildReadWriteManyEntriesCommand

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

Specified by:: buildReadWriteManyEntriesCommand in interface CommandsFactory

buildInvalidateVersionsCommand

public InvalidateVersionsCommand buildInvalidateVersionsCommand(int topologyId,
                                                                Object[] keys,
                                                                int[] topologyIds,
                                                                long[] versions,
                                                                boolean removed)

Specified by:: buildInvalidateVersionsCommand in interface CommandsFactory

buildWriteOnlyKeyCommand

public <K,V> WriteOnlyKeyCommand<K,V> buildWriteOnlyKeyCommand(Object key,
                                                               Consumer<EntryView.WriteEntryView<K,V>> f,
                                                               int segment,
                                                               Params params,
                                                               DataConversion keyDataConversion,
                                                               DataConversion valueDataConversion)

Specified by:: buildWriteOnlyKeyCommand in interface CommandsFactory

buildWriteOnlyKeyValueCommand

public <K,V,T> WriteOnlyKeyValueCommand<K,V,T> buildWriteOnlyKeyValueCommand(Object key,
                                                                             Object argument,
                                                                             BiConsumer<T,EntryView.WriteEntryView<K,V>> f,
                                                                             int segment,
                                                                             Params params,
                                                                             DataConversion keyDataConversion,
                                                                             DataConversion valueDataConversion)

Specified by:: buildWriteOnlyKeyValueCommand in interface CommandsFactory

buildWriteOnlyManyCommand

public <K,V> WriteOnlyManyCommand<K,V> buildWriteOnlyManyCommand(Collection<?> keys,
                                                                 Consumer<EntryView.WriteEntryView<K,V>> f,
                                                                 Params params,
                                                                 DataConversion keyDataConversion,
                                                                 DataConversion valueDataConversion)

Specified by:: buildWriteOnlyManyCommand in interface CommandsFactory

buildWriteOnlyManyEntriesCommand

public <K,V,T> WriteOnlyManyEntriesCommand<K,V,T> buildWriteOnlyManyEntriesCommand(Map<?,?> arguments,
                                                                                   BiConsumer<T,EntryView.WriteEntryView<K,V>> f,
                                                                                   Params params,
                                                                                   DataConversion keyDataConversion,
                                                                                   DataConversion valueDataConversion)

Specified by:: buildWriteOnlyManyEntriesCommand in interface CommandsFactory

buildTxReadOnlyKeyCommand

public <K,V,R> TxReadOnlyKeyCommand<K,V,R> buildTxReadOnlyKeyCommand(Object key,
                                                                     Function<EntryView.ReadEntryView<K,V>,R> f,
                                                                     List<Mutation<K,V,?>> mutations,
                                                                     int segment,
                                                                     Params params,
                                                                     DataConversion keyDataConversion,
                                                                     DataConversion valueDataConversion)

Specified by:: buildTxReadOnlyKeyCommand in interface CommandsFactory

buildTxReadOnlyManyCommand

public <K,V,R> TxReadOnlyManyCommand<K,V,R> buildTxReadOnlyManyCommand(Collection<?> keys,
                                                                       List<List<Mutation<K,V,?>>> mutations,
                                                                       Params params,
                                                                       DataConversion keyDataConversion,
                                                                       DataConversion valueDataConversion)

Specified by:: buildTxReadOnlyManyCommand in interface CommandsFactory

buildBackupAckCommand

public BackupAckCommand buildBackupAckCommand(long id,
                                              int topologyId)

Specified by:: buildBackupAckCommand in interface CommandsFactory

buildBackupMultiKeyAckCommand

public BackupMultiKeyAckCommand buildBackupMultiKeyAckCommand(long id,
                                                              int segment,
                                                              int topologyId)

Specified by:: buildBackupMultiKeyAckCommand in interface CommandsFactory

buildExceptionAckCommand

public ExceptionAckCommand buildExceptionAckCommand(long id,
                                                    Throwable throwable,
                                                    int topologyId)

Specified by:: buildExceptionAckCommand in interface CommandsFactory

buildRevokeBiasCommand

public RevokeBiasCommand buildRevokeBiasCommand(Address ackTarget,
                                                long id,
                                                int topologyId,
                                                Collection<Object> keys)

Specified by:: buildRevokeBiasCommand in interface CommandsFactory

buildRenewBiasCommand
```
public RenewBiasCommand buildRenewBiasCommand(Object[] keys)
```
Specified by:

buildRenewBiasCommand in interface CommandsFactory

buildSingleKeyBackupWriteCommand
```
public SingleKeyBackupWriteCommand buildSingleKeyBackupWriteCommand()
```
Specified by:

buildSingleKeyBackupWriteCommand in interface CommandsFactory

buildSingleKeyFunctionalBackupWriteCommand
```
public SingleKeyFunctionalBackupWriteCommand buildSingleKeyFunctionalBackupWriteCommand()
```
Specified by:

buildSingleKeyFunctionalBackupWriteCommand in interface CommandsFactory

buildPutMapBackupWriteCommand
```
public PutMapBackupWriteCommand buildPutMapBackupWriteCommand()
```
Specified by:

buildPutMapBackupWriteCommand in interface CommandsFactory

buildMultiEntriesFunctionalBackupWriteCommand
```
public MultiEntriesFunctionalBackupWriteCommand buildMultiEntriesFunctionalBackupWriteCommand()
```
Specified by:

buildMultiEntriesFunctionalBackupWriteCommand in interface CommandsFactory

buildMultiKeyFunctionalBackupWriteCommand
```
public MultiKeyFunctionalBackupWriteCommand buildMultiKeyFunctionalBackupWriteCommand()
```
Specified by:

buildMultiKeyFunctionalBackupWriteCommand in interface CommandsFactory

buildKeyReductionPublisherCommand

public <K,R> ReductionPublisherRequestCommand<K> buildKeyReductionPublisherCommand(boolean parallelStream,
                                                                                   DeliveryGuarantee deliveryGuarantee,
                                                                                   IntSet segments,
                                                                                   Set<K> keys,
                                                                                   Set<K> excludedKeys,
                                                                                   boolean includeLoader,
                                                                                   Function<? super org.reactivestreams.Publisher<K>,? extends CompletionStage<R>> transformer,
                                                                                   Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)

Specified by:: buildKeyReductionPublisherCommand in interface CommandsFactory

buildEntryReductionPublisherCommand

public <K,V,R> ReductionPublisherRequestCommand<K> buildEntryReductionPublisherCommand(boolean parallelStream,
                                                                                       DeliveryGuarantee deliveryGuarantee,
                                                                                       IntSet segments,
                                                                                       Set<K> keys,
                                                                                       Set<K> excludedKeys,
                                                                                       boolean includeLoader,
                                                                                       Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> transformer,
                                                                                       Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)

Specified by:: buildEntryReductionPublisherCommand in interface CommandsFactory

buildInitialPublisherCommand

public <K,I,R> InitialPublisherCommand<K,I,R> buildInitialPublisherCommand(String requestId,
                                                                           DeliveryGuarantee deliveryGuarantee,
                                                                           int batchSize,
                                                                           IntSet segments,
                                                                           Set<K> keys,
                                                                           Set<K> excludedKeys,
                                                                           boolean includeLoader,
                                                                           boolean entryStream,
                                                                           boolean trackKeys,
                                                                           Function<? super org.reactivestreams.Publisher<I>,? extends org.reactivestreams.Publisher<R>> transformer)

Specified by:: buildInitialPublisherCommand in interface CommandsFactory

buildNextPublisherCommand
```
public NextPublisherCommand buildNextPublisherCommand(String requestId)
```
Specified by:

buildNextPublisherCommand in interface CommandsFactory

buildCancelPublisherCommand
```
public CancelPublisherCommand buildCancelPublisherCommand(String requestId)
```
Specified by:

buildCancelPublisherCommand in interface CommandsFactory

buildMultiClusterEventCommand

public <K,V> MultiClusterEventCommand<K,V> buildMultiClusterEventCommand(Map<UUID,Collection<ClusterEvent<K,V>>> events)

Specified by:: buildMultiClusterEventCommand in interface CommandsFactory

buildCheckTransactionRpcCommand

public CheckTransactionRpcCommand buildCheckTransactionRpcCommand(Collection<GlobalTransaction> globalTransactions)

Specified by:: buildCheckTransactionRpcCommand in interface CommandsFactory

buildTouchCommand

public TouchCommand buildTouchCommand(Object key,
                                      int segment)

Specified by:: buildTouchCommand in interface CommandsFactory

buildIracPutKeyCommand

public <K,V> IracPutKeyCommand buildIracPutKeyCommand(InternalCacheEntry<K,V> entry)

Specified by:: buildIracPutKeyCommand in interface CommandsFactory

buildIracRemoveKeyCommand

public IracRemoveKeyCommand buildIracRemoveKeyCommand(Object key,
                                                      IracMetadata iracMetadata)

Specified by:: buildIracRemoveKeyCommand in interface CommandsFactory

buildIracClearKeysCommand
```
public IracClearKeysCommand buildIracClearKeysCommand()
```
Specified by:

buildIracClearKeysCommand in interface CommandsFactory

buildIracCleanupKeyCommand

public IracCleanupKeyCommand buildIracCleanupKeyCommand(Object key,
                                                        Object lockOwner,
                                                        IracMetadata tombstone)

Specified by:: buildIracCleanupKeyCommand in interface CommandsFactory

buildIracMetadataRequestCommand
```
public IracMetadataRequestCommand buildIracMetadataRequestCommand(int segment)
```
Specified by:

buildIracMetadataRequestCommand in interface CommandsFactory

buildIracRequestStateCommand
```
public IracRequestStateCommand buildIracRequestStateCommand(IntSet segments)
```
Specified by:

buildIracRequestStateCommand in interface CommandsFactory

buildIracStateResponseCommand

public IracStateResponseCommand buildIracStateResponseCommand(Object key,
                                                              Object lockOwner,
                                                              IracMetadata tombstone)

Specified by:: buildIracStateResponseCommand in interface CommandsFactory

Class CommandsFactoryImpl

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Methods inherited from interface org.infinispan.commands.CommandsFactory

Constructor Detail

CommandsFactoryImpl

Method Detail

start

buildPutKeyValueCommand

buildRemoveCommand

buildInvalidateCommand

buildInvalidateFromL1Command

buildInvalidateFromL1Command

buildRemoveExpiredCommand

buildRemoveExpiredCommand

buildReplaceCommand

buildComputeCommand

buildComputeIfAbsentCommand

buildSizeCommand

buildKeySetCommand

buildEntrySetCommand

buildGetKeyValueCommand

buildGetAllCommand

buildPutMapCommand

buildClearCommand

buildEvictCommand

buildPrepareCommand

buildVersionedPrepareCommand

buildCommitCommand

buildVersionedCommitCommand

buildRollbackCommand

buildSingleRpcCommand

buildClusteredGetCommand

initializeReplicableCommand

buildLockControlCommand

buildLockControlCommand

buildLockControlCommand

buildConflictResolutionStartCommand

buildScatteredStateConfirmRevokeCommand

buildScatteredStateGetKeysCommand

buildStateTransferCancelCommand

buildStateTransferGetListenersCommand

buildStateTransferGetTransactionsCommand

buildStateTransferStartCommand

buildStateResponseCommand

getCacheName

buildGetInDoubtTransactionsCommand

buildTxCompletionNotificationCommand

buildTxCompletionNotificationCommand

buildGetInDoubtTxInfoCommand

buildCompleteTransactionCommand

buildXSiteStateTransferCancelSendCommand

buildXSiteStateTransferClearStatusCommand

buildXSiteStateTransferFinishReceiveCommand

buildXSiteStateTransferFinishSendCommand

buildXSiteStateTransferRestartSendingCommand

buildXSiteStateTransferStartReceiveCommand

buildXSiteStateTransferStartSendCommand

buildXSiteStateTransferStatusRequestCommand

buildXSiteAmendOfflineStatusCommand

buildXSiteBringOnlineCommand

buildXSiteOfflineStatusCommand

buildXSiteStatusCommand

buildXSiteTakeOfflineCommand

buildXSiteStatePushCommand

buildSingleXSiteRpcCommand

buildGetKeysInGroupCommand

buildGetCacheEntryCommand

buildClusteredGetAllCommand

buildReadOnlyKeyCommand

buildReadOnlyManyCommand

buildReadWriteKeyValueCommand

buildReadWriteKeyCommand

buildReadWriteManyCommand

buildReadWriteManyEntriesCommand

buildInvalidateVersionsCommand

buildWriteOnlyKeyCommand

buildWriteOnlyKeyValueCommand

buildWriteOnlyManyCommand