@Deprecated public class OptimisticReplicationInterceptor extends BaseRpcInterceptor
ReplicationInterceptor, this interceptor
only deals with transactional calls. Just like all things to do with Optimistic Locking, it is a requirement that
everything is done in a transaction and the transaction context is available via InvocationContext.getTransaction()
and InvocationContext.getGlobalTransaction().| Modifier and Type | Class and Description |
|---|---|
class |
OptimisticReplicationInterceptor.DataVersionPopulator
Deprecated.
|
defaultSynchronous, rpcManager, txTableconfiguration, log, trace| Constructor and Description |
|---|
OptimisticReplicationInterceptor()
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
broadcastCommit(GlobalTransaction gtx,
InvocationContext ctx)
Deprecated.
|
protected void |
broadcastPrepare(OptimisticPrepareCommand command,
GlobalTransaction gtx,
InvocationContext ctx)
Deprecated.
|
protected void |
broadcastRollback(GlobalTransaction gtx,
InvocationContext ctx)
Deprecated.
|
protected TransactionWorkspace |
getTransactionWorkspace(InvocationContext ctx)
Deprecated.
|
Object |
handleDefault(InvocationContext ctx,
VisitableCommand command)
Deprecated.
The default behaviour of the visitXXX methods, which is to ignore the call and pass the call up to the next
interceptor in the chain.
|
void |
initialize(CommandsFactory commandsFactory)
Deprecated.
|
Object |
visitCommitCommand(InvocationContext ctx,
CommitCommand command)
Deprecated.
Visits a CommitCommand.
|
Object |
visitOptimisticPrepareCommand(InvocationContext ctx,
OptimisticPrepareCommand command)
Deprecated.
Visits a OptimisticPrepareCommand.
|
Object |
visitPutForExternalReadCommand(InvocationContext ctx,
PutForExternalReadCommand command)
Deprecated.
Visits a PutForExternalReadCommand.
|
Object |
visitRollbackCommand(InvocationContext ctx,
RollbackCommand command)
Deprecated.
Visits a RollbackCommand.
|
checkResponses, injectComponents, isLocalModeForced, isSynchronous, isTransactionalAndLocal, replicateCall, replicateCall, replicateCall, replicateCall, skipReplicationOfTransactionMethodgetNext, hasNext, invokeNextInterceptor, setNextvisitClearDataCommand, visitCollection, visitCreateNodeCommand, visitEvictFqnCommand, visitExistsNodeCommand, visitGetChildrenNamesCommand, visitGetDataMapCommand, visitGetKeysCommand, visitGetKeyValueCommand, visitGetNodeCommand, visitGravitateDataCommand, visitInvalidateCommand, visitMoveCommand, visitPrepareCommand, visitPutDataMapCommand, visitPutKeyValueCommand, visitRemoveKeyCommand, visitRemoveNodeCommandpublic OptimisticReplicationInterceptor()
public void initialize(CommandsFactory commandsFactory)
public Object visitOptimisticPrepareCommand(InvocationContext ctx, OptimisticPrepareCommand command) throws Throwable
VisitorvisitOptimisticPrepareCommand in interface VisitorvisitOptimisticPrepareCommand in class AbstractVisitorctx - invocation contextcommand - command to visitThrowable - in the event of problems.public Object visitCommitCommand(InvocationContext ctx, CommitCommand command) throws Throwable
VisitorvisitCommitCommand in interface VisitorvisitCommitCommand in class AbstractVisitorctx - invocation contextcommand - command to visitThrowable - in the event of problems.public Object visitRollbackCommand(InvocationContext ctx, RollbackCommand command) throws Throwable
VisitorvisitRollbackCommand in interface VisitorvisitRollbackCommand in class AbstractVisitorctx - invocation contextcommand - command to visitThrowable - in the event of problems.public Object visitPutForExternalReadCommand(InvocationContext ctx, PutForExternalReadCommand command) throws Throwable
VisitorvisitPutForExternalReadCommand in interface VisitorvisitPutForExternalReadCommand in class AbstractVisitorctx - invocation contextcommand - command to visitThrowable - in the event of problems.public Object handleDefault(InvocationContext ctx, VisitableCommand command) throws Throwable
CommandInterceptorhandleDefault in class CommandInterceptorctx - invocation contextcommand - command to invokeThrowable - in the event of problemsprotected void broadcastPrepare(OptimisticPrepareCommand command, GlobalTransaction gtx, InvocationContext ctx) throws Throwable
Throwableprotected void broadcastCommit(GlobalTransaction gtx, InvocationContext ctx) throws Throwable
Throwableprotected void broadcastRollback(GlobalTransaction gtx, InvocationContext ctx) throws Throwable
Throwableprotected TransactionWorkspace getTransactionWorkspace(InvocationContext ctx) throws CacheException
CacheExceptionCopyright © 2012 JBoss, a division of Red Hat. All Rights Reserved.