@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, txTable
configuration, 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, skipReplicationOfTransactionMethod
getNext, hasNext, invokeNextInterceptor, setNext
visitClearDataCommand, visitCollection, visitCreateNodeCommand, visitEvictFqnCommand, visitExistsNodeCommand, visitGetChildrenNamesCommand, visitGetDataMapCommand, visitGetKeysCommand, visitGetKeyValueCommand, visitGetNodeCommand, visitGravitateDataCommand, visitInvalidateCommand, visitMoveCommand, visitPrepareCommand, visitPutDataMapCommand, visitPutKeyValueCommand, visitRemoveKeyCommand, visitRemoveNodeCommand
public OptimisticReplicationInterceptor()
public void initialize(CommandsFactory commandsFactory)
public Object visitOptimisticPrepareCommand(InvocationContext ctx, OptimisticPrepareCommand command) throws Throwable
Visitor
visitOptimisticPrepareCommand
in interface Visitor
visitOptimisticPrepareCommand
in class AbstractVisitor
ctx
- invocation contextcommand
- command to visitThrowable
- in the event of problems.public Object visitCommitCommand(InvocationContext ctx, CommitCommand command) throws Throwable
Visitor
visitCommitCommand
in interface Visitor
visitCommitCommand
in class AbstractVisitor
ctx
- invocation contextcommand
- command to visitThrowable
- in the event of problems.public Object visitRollbackCommand(InvocationContext ctx, RollbackCommand command) throws Throwable
Visitor
visitRollbackCommand
in interface Visitor
visitRollbackCommand
in class AbstractVisitor
ctx
- invocation contextcommand
- command to visitThrowable
- in the event of problems.public Object visitPutForExternalReadCommand(InvocationContext ctx, PutForExternalReadCommand command) throws Throwable
Visitor
visitPutForExternalReadCommand
in interface Visitor
visitPutForExternalReadCommand
in class AbstractVisitor
ctx
- invocation contextcommand
- command to visitThrowable
- in the event of problems.public Object handleDefault(InvocationContext ctx, VisitableCommand command) throws Throwable
CommandInterceptor
handleDefault
in class CommandInterceptor
ctx
- invocation contextcommand
- command to invokeThrowable
- in the event of problemsprotected void broadcastPrepare(OptimisticPrepareCommand command, GlobalTransaction gtx, InvocationContext ctx) throws Throwable
Throwable
protected void broadcastCommit(GlobalTransaction gtx, InvocationContext ctx) throws Throwable
Throwable
protected void broadcastRollback(GlobalTransaction gtx, InvocationContext ctx) throws Throwable
Throwable
protected TransactionWorkspace getTransactionWorkspace(InvocationContext ctx) throws CacheException
CacheException
Copyright © 2012 JBoss, a division of Red Hat. All Rights Reserved.