public abstract class BaseRpcInterceptor extends CommandInterceptor
Modifier and Type | Field and Description |
---|---|
protected boolean |
defaultSynchronous |
protected RpcManager |
rpcManager |
cacheConfiguration
Constructor and Description |
---|
BaseRpcInterceptor() |
getLockAcquisitionTimeout, getLog, getNext, handleDefault, hasNext, hasSkipLocking, injectConfiguration, invokeNextInterceptor, setNext
visitApplyDeltaCommand, visitClearCommand, visitCollection, visitCommitCommand, visitDistributedExecuteCommand, visitEntrySetCommand, visitEvictCommand, visitGetKeyValueCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitLockControlCommand, visitPrepareCommand, visitPutKeyValueCommand, visitPutMapCommand, visitRemoveCommand, visitReplaceCommand, visitRollbackCommand, visitSizeCommand, visitUnknownCommand, visitValuesCommand
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> totalOrderAnycastPrepare(Collection<Address> recipients, PrepareCommand prepareCommand, ResponseFilter responseFilter)
protected final Map<Address,Response> totalOrderBroadcastPrepare(PrepareCommand prepareCommand, ResponseFilter responseFilter)
protected final boolean isSyncCommitPhase()
protected final ResponseFilter getSelfDeliverFilter()
protected final ResponseFilter getIgnoreExtraResponseFilter(Collection<Address> recipients)
Copyright © 2014 JBoss, a division of Red Hat. All Rights Reserved.