@Deprecated public abstract class BaseRpcInterceptor extends CommandInterceptor
Modifier and Type | Field and Description |
---|---|
protected boolean |
defaultSynchronous
Deprecated.
|
protected RpcManager |
rpcManager
Deprecated.
|
protected boolean |
trace
Deprecated.
|
cacheConfiguration
Constructor and Description |
---|
BaseRpcInterceptor()
Deprecated.
|
getCacheWithFlags, getLockAcquisitionTimeout, getLog, getNext, handleDefault, hasNext, hasSkipLocking, injectConfiguration, invokeNextInterceptor, setNext
visitApplyDeltaCommand, visitClearCommand, visitCollection, visitCommitCommand, visitDistributedExecuteCommand, visitEntrySetCommand, visitEvictCommand, visitGetAllCommand, visitGetCacheEntryCommand, visitGetKeysInGroupCommand, visitGetKeyValueCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitLockControlCommand, visitPrepareCommand, visitPutKeyValueCommand, visitPutMapCommand, visitReadOnlyKeyCommand, visitReadOnlyManyCommand, visitReadWriteKeyCommand, visitReadWriteKeyValueCommand, visitReadWriteManyCommand, visitReadWriteManyEntriesCommand, visitRemoveCommand, visitReplaceCommand, visitRollbackCommand, visitSizeCommand, visitUnknownCommand, visitWriteOnlyKeyCommand, visitWriteOnlyKeyValueCommand, visitWriteOnlyManyCommand, visitWriteOnlyManyEntriesCommand
protected boolean trace
protected RpcManager rpcManager
protected boolean defaultSynchronous
public void inject(RpcManager rpcManager, StateConsumer stateConsumer)
public void init()
protected final boolean isSynchronous(FlagAffectedCommand command)
protected final boolean isLocalModeForced(FlagAffectedCommand command)
protected boolean shouldInvokeRemoteTxCommand(TxInvocationContext ctx)
protected static void transactionRemotelyPrepared(TxInvocationContext ctx)
protected static void totalOrderTxCommit(TxInvocationContext ctx)
protected static void totalOrderTxRollback(TxInvocationContext ctx)
protected static boolean shouldTotalOrderRollbackBeInvokedRemotely(TxInvocationContext ctx)
protected final Map<Address,Response> totalOrderPrepare(Collection<Address> recipients, PrepareCommand prepareCommand, TimeoutValidationResponseFilter responseFilter)
protected final boolean isSyncCommitPhase()
protected final TimeoutValidationResponseFilter getSelfDeliverFilter()
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.