public class DistributionInterceptor extends BaseRpcInterceptor
defaultSynchronous, rpcManagerconfiguration| Constructor and Description |
|---|
DistributionInterceptor() |
init, init, isLocalModeForced, isSynchronous, shouldInvokeRemoteTxCommandgetNext, handleDefault, hasNext, invokeNextInterceptor, setNextvisitApplyDeltaCommand, visitCollection, visitDistributedExecuteCommand, visitEntrySetCommand, visitEvictCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitSizeCommand, visitUnknownCommand, visitValuesCommandprotected Log getLog()
getLog in class CommandInterceptorpublic void injectDependencies(DistributionManager distributionManager, StateTransferLock stateTransferLock, CommandsFactory cf, DataContainer dataContainer, EntryFactory entryFactory, L1Manager l1Manager, LockManager lockManager)
public void start()
public Object visitGetKeyValueCommand(InvocationContext ctx, GetKeyValueCommand command) throws Throwable
visitGetKeyValueCommand in interface VisitorvisitGetKeyValueCommand in class AbstractVisitorThrowablepublic Object visitPutKeyValueCommand(InvocationContext ctx, PutKeyValueCommand command) throws Throwable
visitPutKeyValueCommand in interface VisitorvisitPutKeyValueCommand in class AbstractVisitorThrowablepublic Object visitPutMapCommand(InvocationContext ctx, PutMapCommand command) throws Throwable
visitPutMapCommand in interface VisitorvisitPutMapCommand in class AbstractVisitorThrowablepublic Object visitRemoveCommand(InvocationContext ctx, RemoveCommand command) throws Throwable
visitRemoveCommand in interface VisitorvisitRemoveCommand in class AbstractVisitorThrowablepublic Object visitClearCommand(InvocationContext ctx, ClearCommand command) throws Throwable
visitClearCommand in interface VisitorvisitClearCommand in class AbstractVisitorThrowablepublic Object visitReplaceCommand(InvocationContext ctx, ReplaceCommand command) throws Throwable
visitReplaceCommand in interface VisitorvisitReplaceCommand in class AbstractVisitorThrowablepublic Object visitLockControlCommand(TxInvocationContext ctx, LockControlCommand command) throws Throwable
visitLockControlCommand in interface VisitorvisitLockControlCommand in class BaseRpcInterceptorThrowablepublic Object visitCommitCommand(TxInvocationContext ctx, CommitCommand command) throws Throwable
visitCommitCommand in interface VisitorvisitCommitCommand in class AbstractVisitorThrowableprotected PrepareCommand buildPrepareCommandForResend(TxInvocationContext ctx, CommitCommand command)
public Object visitPrepareCommand(TxInvocationContext ctx, PrepareCommand command) throws Throwable
visitPrepareCommand in interface VisitorvisitPrepareCommand in class AbstractVisitorThrowableprotected void prepareOnAffectedNodes(TxInvocationContext ctx, PrepareCommand command, Collection<Address> recipients, boolean sync)
public Object visitRollbackCommand(TxInvocationContext ctx, RollbackCommand command) throws Throwable
visitRollbackCommand in interface VisitorvisitRollbackCommand in class AbstractVisitorThrowableCopyright © 2012 JBoss by Red Hat. All Rights Reserved.