public class ReplicationInterceptor extends BaseRpcInterceptor
defaultSynchronous, rpcManager
configuration
Constructor and Description |
---|
ReplicationInterceptor() |
Modifier and Type | Method and Description |
---|---|
protected void |
broadcastPrepare(TxInvocationContext context,
PrepareCommand command) |
protected PrepareCommand |
buildPrepareCommandForResend(TxInvocationContext ctx,
CommitCommand command) |
protected Log |
getLog() |
void |
init(StateTransferLock stateTransferLock,
CommandsFactory cf) |
Object |
visitClearCommand(InvocationContext ctx,
ClearCommand command) |
Object |
visitCommitCommand(TxInvocationContext ctx,
CommitCommand command) |
Object |
visitPrepareCommand(TxInvocationContext ctx,
PrepareCommand command) |
Object |
visitPutKeyValueCommand(InvocationContext ctx,
PutKeyValueCommand command) |
Object |
visitPutMapCommand(InvocationContext ctx,
PutMapCommand command) |
Object |
visitRemoveCommand(InvocationContext ctx,
RemoveCommand command) |
Object |
visitReplaceCommand(InvocationContext ctx,
ReplaceCommand command) |
Object |
visitRollbackCommand(TxInvocationContext ctx,
RollbackCommand command) |
init, init, isLocalModeForced, isSynchronous, shouldInvokeRemoteTxCommand, visitLockControlCommand
getNext, handleDefault, hasNext, invokeNextInterceptor, setNext
visitApplyDeltaCommand, visitCollection, visitDistributedExecuteCommand, visitEntrySetCommand, visitEvictCommand, visitGetKeyValueCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitSizeCommand, visitUnknownCommand, visitValuesCommand
protected Log getLog()
getLog
in class CommandInterceptor
public void init(StateTransferLock stateTransferLock, CommandsFactory cf)
public Object visitCommitCommand(TxInvocationContext ctx, CommitCommand command) throws Throwable
visitCommitCommand
in interface Visitor
visitCommitCommand
in class AbstractVisitor
Throwable
protected PrepareCommand buildPrepareCommandForResend(TxInvocationContext ctx, CommitCommand command)
public Object visitPrepareCommand(TxInvocationContext ctx, PrepareCommand command) throws Throwable
visitPrepareCommand
in interface Visitor
visitPrepareCommand
in class AbstractVisitor
Throwable
protected void broadcastPrepare(TxInvocationContext context, PrepareCommand command)
public Object visitRollbackCommand(TxInvocationContext ctx, RollbackCommand command) throws Throwable
visitRollbackCommand
in interface Visitor
visitRollbackCommand
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 visitRemoveCommand(InvocationContext ctx, RemoveCommand command) throws Throwable
visitRemoveCommand
in interface Visitor
visitRemoveCommand
in class AbstractVisitor
Throwable
public Object visitClearCommand(InvocationContext ctx, ClearCommand command) throws Throwable
visitClearCommand
in interface Visitor
visitClearCommand
in class AbstractVisitor
Throwable
public Object visitReplaceCommand(InvocationContext ctx, ReplaceCommand command) throws Throwable
visitReplaceCommand
in interface Visitor
visitReplaceCommand
in class AbstractVisitor
Throwable
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.