|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jboss.cache.commands.AbstractVisitor
org.jboss.cache.interceptors.base.CommandInterceptor
org.jboss.cache.interceptors.BaseRpcInterceptor
org.jboss.cache.interceptors.InvalidationInterceptor
public class InvalidationInterceptor
This interceptor acts as a replacement to the replication interceptor when the CacheImpl is configured with ClusteredSyncMode as INVALIDATE.
The idea is that rather than replicating changes to all caches in a cluster when CRUD (Create, Remove, Update, Delete) methods are called, simply call evict(Fqn) on the remote caches for each changed node. This allows the remote node to look up the value in a shared cache loader which would have been updated with the changes.
Nested Class Summary | |
---|---|
static class |
InvalidationInterceptor.InvalidationFilterVisitor
|
Field Summary | |
---|---|
protected boolean |
optimistic
|
protected Map<GlobalTransaction,List<ReversibleCommand>> |
txMods
|
Fields inherited from class org.jboss.cache.interceptors.BaseRpcInterceptor |
---|
defaultSynchronous, rpcManager, txTable |
Fields inherited from class org.jboss.cache.interceptors.base.CommandInterceptor |
---|
configuration, log, trace |
Constructor Summary | |
---|---|
InvalidationInterceptor()
|
Methods inherited from class org.jboss.cache.interceptors.BaseRpcInterceptor |
---|
checkResponses, injectComponents, isLocalModeForced, isSynchronous, isTransactionalAndLocal, replicateCall, replicateCall, replicateCall, replicateCall, skipReplicationOfTransactionMethod |
Methods inherited from class org.jboss.cache.interceptors.base.CommandInterceptor |
---|
getNext, getStatisticsEnabled, handleDefault, hasNext, invokeNextInterceptor, setNext, setStatisticsEnabled |
Methods inherited from class org.jboss.cache.commands.AbstractVisitor |
---|
visitCollection, visitCreateNodeCommand, visitEvictFqnCommand, visitExistsNodeCommand, visitGetChildrenNamesCommand, visitGetDataMapCommand, visitGetKeysCommand, visitGetKeyValueCommand, visitGetNodeCommand, visitGravitateDataCommand, visitInvalidateCommand |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.jboss.cache.interceptors.InterceptorMBean |
---|
getStatisticsEnabled, setStatisticsEnabled |
Field Detail |
---|
protected Map<GlobalTransaction,List<ReversibleCommand>> txMods
protected boolean optimistic
Constructor Detail |
---|
public InvalidationInterceptor()
Method Detail |
---|
public void injectDependencies(CommandsFactory commandsFactory)
public Object visitPutDataMapCommand(InvocationContext ctx, PutDataMapCommand command) throws Throwable
Visitor
visitPutDataMapCommand
in interface Visitor
visitPutDataMapCommand
in class AbstractVisitor
ctx
- invocation contextcommand
- command to visit
Throwable
- 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 visit
Throwable
- in the event of problems.public Object visitPutKeyValueCommand(InvocationContext ctx, PutKeyValueCommand command) throws Throwable
Visitor
visitPutKeyValueCommand
in interface Visitor
visitPutKeyValueCommand
in class AbstractVisitor
ctx
- invocation contextcommand
- command to visit
Throwable
- in the event of problems.public Object visitRemoveNodeCommand(InvocationContext ctx, RemoveNodeCommand command) throws Throwable
Visitor
visitRemoveNodeCommand
in interface Visitor
visitRemoveNodeCommand
in class AbstractVisitor
ctx
- invocation contextcommand
- command to visit
Throwable
- in the event of problems.public Object visitRemoveKeyCommand(InvocationContext ctx, RemoveKeyCommand command) throws Throwable
Visitor
visitRemoveKeyCommand
in interface Visitor
visitRemoveKeyCommand
in class AbstractVisitor
ctx
- invocation contextcommand
- command to visit
Throwable
- in the event of problems.public Object visitMoveCommand(InvocationContext ctx, MoveCommand command) throws Throwable
Visitor
visitMoveCommand
in interface Visitor
visitMoveCommand
in class AbstractVisitor
ctx
- invocation contextcommand
- command to visit
Throwable
- in the event of problems.public Object visitClearDataCommand(InvocationContext ctx, ClearDataCommand command) throws Throwable
Visitor
visitClearDataCommand
in interface Visitor
visitClearDataCommand
in class AbstractVisitor
ctx
- invocation contextcommand
- command to visit
Throwable
- in the event of problems.public Object visitPrepareCommand(InvocationContext ctx, PrepareCommand command) throws Throwable
Visitor
visitPrepareCommand
in interface Visitor
visitPrepareCommand
in class AbstractVisitor
ctx
- invocation contextcommand
- command to visit
Throwable
- in the event of problems.public Object visitOptimisticPrepareCommand(InvocationContext ctx, OptimisticPrepareCommand command) throws Throwable
Visitor
visitOptimisticPrepareCommand
in interface Visitor
visitOptimisticPrepareCommand
in class AbstractVisitor
ctx
- invocation contextcommand
- command to visit
Throwable
- 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 visit
Throwable
- 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 visit
Throwable
- in the event of problems.public long getInvalidations()
InvalidationInterceptorMBean
getInvalidations
in interface InvalidationInterceptorMBean
public void resetStatistics()
CommandInterceptor
resetStatistics
in interface InterceptorMBean
resetStatistics
in class CommandInterceptor
public Map<String,Object> dumpStatistics()
CommandInterceptor
dumpStatistics
in interface InterceptorMBean
dumpStatistics
in class CommandInterceptor
protected void invalidateAcrossCluster(Fqn fqn, TransactionWorkspace workspace, boolean synchronous, InvocationContext ctx) throws Throwable
Throwable
protected DataVersion getNodeVersion(TransactionWorkspace w, Fqn f)
protected TransactionWorkspace getWorkspace(InvocationContext ctx)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |