public class TxDistributionInterceptor extends BaseDistributionInterceptor
BaseDistributionInterceptor.ReadManyCommandHelper<C extends VisitableCommand>, BaseDistributionInterceptor.ReadOnlyManyHelper
ClusteringInterceptor.ClusteredGetAllFuture
expirationManager, isL1Enabled, isReplicated, keyPartitioner, rvrl, timeService
cf, dataContainer, distributionManager, entryFactory, lockManager
componentRegistry, defaultSynchronous, rpcManager
cacheConfiguration
Constructor and Description |
---|
TxDistributionInterceptor() |
checkTopologyId, getLog, handleFunctionalReadManyCommand, handleNonTxWriteCommand, invokeRemotely, primaryReturnHandler, readNeedsRemoteValue, remoteGetMany, retrieveDistributionInfo, unwrapFunctionalManyResultOnOrigin, unwrapFunctionalResultOnOrigin, visitClearCommand, visitGetAllCommand, visitGetCacheEntryCommand, visitGetKeysInGroupCommand, visitGetKeyValueCommand, visitReadOnlyKeyCommand, wrapFunctionalManyResultOnNonOrigin, wrapFunctionalResultOnNonOriginOnReturn, wrapRemoteEntry
getSuccessfulResponseOrFail, unexpected
init, isLocalModeForced, isSynchronous, shouldInvokeRemoteTxCommand, transactionRemotelyPrepared
handleDefault, visitCommand, visitEntrySetCommand, visitEvictCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitSizeCommand, visitUnknownCommand
asyncInvokeNext, asyncInvokeNext, asyncInvokeNext, asyncValue, delayedNull, delayedValue, delayedValue, invokeNext, invokeNextAndExceptionally, invokeNextAndFinally, invokeNextAndHandle, invokeNextThenAccept, invokeNextThenApply, isSuccessfullyDone, makeStage, setNextInterceptor, valueOrException
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
visitRemoveExpiredCommand
public void configure()
configure
in class BaseDistributionInterceptor
public Object visitReplaceCommand(InvocationContext ctx, ReplaceCommand command) throws Throwable
visitReplaceCommand
in interface Visitor
visitReplaceCommand
in class DDAsyncInterceptor
Throwable
public Object visitComputeCommand(InvocationContext ctx, ComputeCommand command) throws Throwable
visitComputeCommand
in interface Visitor
visitComputeCommand
in class DDAsyncInterceptor
Throwable
public Object visitComputeIfAbsentCommand(InvocationContext ctx, ComputeIfAbsentCommand command) throws Throwable
visitComputeIfAbsentCommand
in interface Visitor
visitComputeIfAbsentCommand
in class DDAsyncInterceptor
Throwable
public Object visitRemoveCommand(InvocationContext ctx, RemoveCommand command) throws Throwable
visitRemoveCommand
in interface Visitor
visitRemoveCommand
in class DDAsyncInterceptor
Throwable
public Object visitPutKeyValueCommand(InvocationContext ctx, PutKeyValueCommand command) throws Throwable
visitPutKeyValueCommand
in interface Visitor
visitPutKeyValueCommand
in class DDAsyncInterceptor
Throwable
public Object visitPutMapCommand(InvocationContext ctx, PutMapCommand command) throws Throwable
visitPutMapCommand
in interface Visitor
visitPutMapCommand
in class DDAsyncInterceptor
Throwable
public Object visitLockControlCommand(TxInvocationContext ctx, LockControlCommand command) throws Throwable
visitLockControlCommand
in interface Visitor
visitLockControlCommand
in class DDAsyncInterceptor
Throwable
public Object visitWriteOnlyKeyCommand(InvocationContext ctx, WriteOnlyKeyCommand command) throws Throwable
visitWriteOnlyKeyCommand
in interface Visitor
visitWriteOnlyKeyCommand
in class DDAsyncInterceptor
Throwable
public Object visitReadWriteKeyValueCommand(InvocationContext ctx, ReadWriteKeyValueCommand command) throws Throwable
visitReadWriteKeyValueCommand
in interface Visitor
visitReadWriteKeyValueCommand
in class DDAsyncInterceptor
Throwable
public Object visitReadWriteKeyCommand(InvocationContext ctx, ReadWriteKeyCommand command) throws Throwable
visitReadWriteKeyCommand
in interface Visitor
visitReadWriteKeyCommand
in class DDAsyncInterceptor
Throwable
public Object visitWriteOnlyManyEntriesCommand(InvocationContext ctx, WriteOnlyManyEntriesCommand command) throws Throwable
visitWriteOnlyManyEntriesCommand
in interface Visitor
visitWriteOnlyManyEntriesCommand
in class DDAsyncInterceptor
Throwable
public Object visitWriteOnlyKeyValueCommand(InvocationContext ctx, WriteOnlyKeyValueCommand command) throws Throwable
visitWriteOnlyKeyValueCommand
in interface Visitor
visitWriteOnlyKeyValueCommand
in class DDAsyncInterceptor
Throwable
public Object visitWriteOnlyManyCommand(InvocationContext ctx, WriteOnlyManyCommand command) throws Throwable
visitWriteOnlyManyCommand
in interface Visitor
visitWriteOnlyManyCommand
in class DDAsyncInterceptor
Throwable
public Object visitReadWriteManyCommand(InvocationContext ctx, ReadWriteManyCommand command) throws Throwable
visitReadWriteManyCommand
in interface Visitor
visitReadWriteManyCommand
in class DDAsyncInterceptor
Throwable
public Object visitReadWriteManyEntriesCommand(InvocationContext ctx, ReadWriteManyEntriesCommand command) throws Throwable
visitReadWriteManyEntriesCommand
in interface Visitor
visitReadWriteManyEntriesCommand
in class DDAsyncInterceptor
Throwable
public Object visitCommitCommand(TxInvocationContext ctx, CommitCommand command) throws Throwable
visitCommitCommand
in interface Visitor
visitCommitCommand
in class DDAsyncInterceptor
Throwable
public Object visitPrepareCommand(TxInvocationContext ctx, PrepareCommand command) throws Throwable
visitPrepareCommand
in interface Visitor
visitPrepareCommand
in class DDAsyncInterceptor
Throwable
protected CompletionStage<Object> prepareOnAffectedNodes(TxInvocationContext<?> ctx, PrepareCommand command, Collection<Address> recipients)
public Object visitRollbackCommand(TxInvocationContext ctx, RollbackCommand command) throws Throwable
visitRollbackCommand
in interface Visitor
visitRollbackCommand
in class DDAsyncInterceptor
Throwable
protected void checkTxCommandResponses(Map<Address,Response> responseMap, TransactionBoundaryCommand command, TxInvocationContext<LocalTransaction> context, Collection<Address> recipients, PrepareResponse prepareResponse)
protected <C extends TopologyAffectedCommand & FlagAffectedCommand,K,V> Object handleTxWriteManyEntriesCommand(InvocationContext ctx, C command, Map<K,V> entries, BiFunction<C,Map<K,V>,C> copyCommand)
protected <C extends VisitableCommand & FlagAffectedCommand & TopologyAffectedCommand,K> Object handleTxWriteManyCommand(InvocationContext ctx, C command, Collection<K> keys, BiFunction<C,List<K>,C> copyCommand)
public <C extends AbstractDataWriteCommand & FunctionalCommand> Object handleTxFunctionalCommand(InvocationContext ctx, C command)
public Object visitReadOnlyManyCommand(InvocationContext ctx, ReadOnlyManyCommand command) throws Throwable
visitReadOnlyManyCommand
in interface Visitor
visitReadOnlyManyCommand
in class BaseDistributionInterceptor
Throwable
protected ReadOnlyKeyCommand remoteReadOnlyCommand(InvocationContext ctx, ReadOnlyKeyCommand command)
remoteReadOnlyCommand
in class BaseDistributionInterceptor
protected <C extends FlagAffectedCommand & TopologyAffectedCommand> CompletionStage<Void> remoteGetSingleKey(InvocationContext ctx, C command, Object key, boolean isWrite)
BaseDistributionInterceptor
remoteGetSingleKey
in class BaseDistributionInterceptor
protected void handleRemotelyRetrievedKeys(InvocationContext ctx, WriteCommand appliedCommand, List<?> remoteKeys)
handleRemotelyRetrievedKeys
in class BaseDistributionInterceptor
Copyright © 2021 JBoss by Red Hat. All rights reserved.