@Deprecated public class TxDistributionInterceptor extends BaseDistributionInterceptor
cdl, dm, isL1Enabled, rvrl
cf, dataContainer, entryFactory, lockManager, stateTransferManager
defaultSynchronous, rpcManager
cacheConfiguration
Constructor and Description |
---|
TxDistributionInterceptor()
Deprecated.
|
configure, fetchValueLocallyIfAvailable, getLog, handleNonTxWriteCommand, injectDependencies, isValueAvailableLocally, readNeedsRemoteValue, retrieveFromRemoteSource, retrieveFromRemoteSources, valueIsMissing, visitClearCommand, visitGetAllCommand, visitGetKeysInGroupCommand, visitReadOnlyManyCommand
injectDependencies
getSelfDeliverFilter, init, inject, isLocalModeForced, isSyncCommitPhase, isSynchronous, shouldInvokeRemoteTxCommand, shouldTotalOrderRollbackBeInvokedRemotely, totalOrderPrepare, totalOrderTxCommit, totalOrderTxRollback, transactionRemotelyPrepared
getCacheWithFlags, getLockAcquisitionTimeout, getNext, handleDefault, hasNext, hasSkipLocking, injectConfiguration, invokeNextInterceptor, setNext
visitApplyDeltaCommand, visitCollection, visitDistributedExecuteCommand, visitEntrySetCommand, visitEvictCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitReadOnlyKeyCommand, visitReadWriteKeyCommand, visitReadWriteKeyValueCommand, visitReadWriteManyCommand, visitReadWriteManyEntriesCommand, visitSizeCommand, visitUnknownCommand, visitWriteOnlyKeyCommand, visitWriteOnlyKeyValueCommand, visitWriteOnlyManyCommand, visitWriteOnlyManyEntriesCommand
public void inject(PartitionHandlingManager partitionHandlingManager)
public void start()
public Object visitReplaceCommand(InvocationContext ctx, ReplaceCommand command) throws Throwable
visitReplaceCommand
in interface Visitor
visitReplaceCommand
in class AbstractVisitor
Throwable
public Object visitRemoveCommand(InvocationContext ctx, RemoveCommand command) throws Throwable
visitRemoveCommand
in interface Visitor
visitRemoveCommand
in class AbstractVisitor
Throwable
public Object visitPutKeyValueCommand(InvocationContext ctx, PutKeyValueCommand command) throws Throwable
visitPutKeyValueCommand
in interface Visitor
visitPutKeyValueCommand
in class AbstractVisitor
Throwable
public Object visitPutMapCommand(InvocationContext ctx, PutMapCommand command) throws Throwable
visitPutMapCommand
in interface Visitor
visitPutMapCommand
in class AbstractVisitor
Throwable
public Object visitGetKeyValueCommand(InvocationContext ctx, GetKeyValueCommand command) throws Throwable
visitGetKeyValueCommand
in interface Visitor
visitGetKeyValueCommand
in class AbstractVisitor
Throwable
public Object visitGetCacheEntryCommand(InvocationContext ctx, GetCacheEntryCommand command) throws Throwable
visitGetCacheEntryCommand
in interface Visitor
visitGetCacheEntryCommand
in class AbstractVisitor
Throwable
public Object visitLockControlCommand(TxInvocationContext ctx, LockControlCommand command) throws Throwable
visitLockControlCommand
in interface Visitor
visitLockControlCommand
in class AbstractVisitor
Throwable
public Object visitCommitCommand(TxInvocationContext ctx, CommitCommand command) throws Throwable
visitCommitCommand
in interface Visitor
visitCommitCommand
in class AbstractVisitor
Throwable
public Object visitPrepareCommand(TxInvocationContext ctx, PrepareCommand command) throws Throwable
visitPrepareCommand
in interface Visitor
visitPrepareCommand
in class AbstractVisitor
Throwable
protected void prepareOnAffectedNodes(TxInvocationContext<?> ctx, PrepareCommand command, Collection<Address> recipients)
public Object visitRollbackCommand(TxInvocationContext ctx, RollbackCommand command) throws Throwable
visitRollbackCommand
in interface Visitor
visitRollbackCommand
in class AbstractVisitor
Throwable
protected void checkTxCommandResponses(Map<Address,Response> responseMap, TransactionBoundaryCommand command, LocalTxInvocationContext context, Collection<Address> recipients)
protected boolean writeNeedsRemoteValue(InvocationContext ctx, WriteCommand command, Object key)
writeNeedsRemoteValue
in class BaseDistributionInterceptor
protected void remoteGetBeforeWrite(InvocationContext ctx, WriteCommand command, Object key) throws Throwable
remoteGetBeforeWrite
in class BaseDistributionInterceptor
Throwable
protected InternalCacheEntry remoteGet(InvocationContext ctx, Object key, boolean isWrite, FlagAffectedCommand command) throws Throwable
Throwable
protected RpcOptions createPrepareRpcOptions()
Copyright © 2017 JBoss, a division of Red Hat. All rights reserved.