Class NonTxInvalidationInterceptor
- java.lang.Object
-
- org.infinispan.interceptors.BaseAsyncInterceptor
-
- org.infinispan.interceptors.DDAsyncInterceptor
-
- org.infinispan.interceptors.impl.BaseRpcInterceptor
-
- org.infinispan.hibernate.cache.commons.access.BaseInvalidationInterceptor
-
- org.infinispan.hibernate.cache.commons.access.NonTxInvalidationInterceptor
-
- All Implemented Interfaces:
org.infinispan.commands.Visitor
,org.infinispan.interceptors.AsyncInterceptor
,org.infinispan.jmx.JmxStatisticsExposer
public class NonTxInvalidationInterceptor extends BaseInvalidationInterceptor
This interceptor should completely replace default InvalidationInterceptor. We need to send custom invalidation commands with transaction identifier (as the invalidation) since we have to do a two-phase invalidation (releasing the locks as JTA synchronization), although the cache itself is non-transactional.- Author:
- Radim Vansa <rvansa@redhat.com>, Mircea.Markus@jboss.com, Galder ZamarreƱo
-
-
Field Summary
-
Fields inherited from class org.infinispan.hibernate.cache.commons.access.BaseInvalidationInterceptor
cache, cacheName, commandsFactory, distributionManager, statisticsEnabled, syncRpcOptions
-
-
Constructor Summary
Constructors Constructor Description NonTxInvalidationInterceptor()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected org.infinispan.util.logging.Log
getLog()
Object
visitClearCommand(org.infinispan.context.InvocationContext ctx, org.infinispan.commands.write.ClearCommand command)
Object
visitPutKeyValueCommand(org.infinispan.context.InvocationContext ctx, org.infinispan.commands.write.PutKeyValueCommand command)
Object
visitPutMapCommand(org.infinispan.context.InvocationContext ctx, org.infinispan.commands.write.PutMapCommand command)
Object
visitRemoveCommand(org.infinispan.context.InvocationContext ctx, org.infinispan.commands.write.RemoveCommand command)
Object
visitReplaceCommand(org.infinispan.context.InvocationContext ctx, org.infinispan.commands.write.ReplaceCommand command)
-
Methods inherited from class org.infinispan.hibernate.cache.commons.access.BaseInvalidationInterceptor
getInvalidations, getMembers, getStatisticsEnabled, incrementInvalidations, isPutForExternalRead, resetStatistics, setStatisticsEnabled
-
Methods inherited from class org.infinispan.interceptors.impl.BaseRpcInterceptor
init, isLocalModeForced, isSynchronous, shouldInvokeRemoteTxCommand, shouldTotalOrderRollbackBeInvokedRemotely, totalOrderPrepare, totalOrderTxCommit, totalOrderTxRollback, transactionRemotelyPrepared
-
Methods inherited from class org.infinispan.interceptors.DDAsyncInterceptor
handleDefault, visitCommand, visitCommitCommand, visitComputeCommand, visitComputeIfAbsentCommand, visitDistributedExecuteCommand, visitEntrySetCommand, visitEvictCommand, visitGetAllCommand, visitGetCacheEntryCommand, visitGetKeysInGroupCommand, visitGetKeyValueCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitLockControlCommand, visitPrepareCommand, visitReadOnlyKeyCommand, visitReadOnlyManyCommand, visitReadWriteKeyCommand, visitReadWriteKeyValueCommand, visitReadWriteManyCommand, visitReadWriteManyEntriesCommand, visitRollbackCommand, visitSizeCommand, visitUnknownCommand, visitWriteOnlyKeyCommand, visitWriteOnlyKeyValueCommand, visitWriteOnlyManyCommand, visitWriteOnlyManyEntriesCommand
-
Methods inherited from class org.infinispan.interceptors.BaseAsyncInterceptor
asyncInvokeNext, asyncInvokeNext, asyncValue, invokeNext, invokeNextAndExceptionally, invokeNextAndFinally, invokeNextAndHandle, invokeNextThenAccept, invokeNextThenApply, isSuccessfullyDone, makeStage, setNextInterceptor, valueOrException
-
-
-
-
Method Detail
-
visitPutKeyValueCommand
public Object visitPutKeyValueCommand(org.infinispan.context.InvocationContext ctx, org.infinispan.commands.write.PutKeyValueCommand command)
- Specified by:
visitPutKeyValueCommand
in interfaceorg.infinispan.commands.Visitor
- Overrides:
visitPutKeyValueCommand
in classorg.infinispan.interceptors.DDAsyncInterceptor
-
visitReplaceCommand
public Object visitReplaceCommand(org.infinispan.context.InvocationContext ctx, org.infinispan.commands.write.ReplaceCommand command)
- Specified by:
visitReplaceCommand
in interfaceorg.infinispan.commands.Visitor
- Overrides:
visitReplaceCommand
in classorg.infinispan.interceptors.DDAsyncInterceptor
-
visitRemoveCommand
public Object visitRemoveCommand(org.infinispan.context.InvocationContext ctx, org.infinispan.commands.write.RemoveCommand command)
- Specified by:
visitRemoveCommand
in interfaceorg.infinispan.commands.Visitor
- Overrides:
visitRemoveCommand
in classorg.infinispan.interceptors.DDAsyncInterceptor
-
visitClearCommand
public Object visitClearCommand(org.infinispan.context.InvocationContext ctx, org.infinispan.commands.write.ClearCommand command)
- Specified by:
visitClearCommand
in interfaceorg.infinispan.commands.Visitor
- Overrides:
visitClearCommand
in classorg.infinispan.interceptors.DDAsyncInterceptor
-
visitPutMapCommand
public Object visitPutMapCommand(org.infinispan.context.InvocationContext ctx, org.infinispan.commands.write.PutMapCommand command)
- Specified by:
visitPutMapCommand
in interfaceorg.infinispan.commands.Visitor
- Overrides:
visitPutMapCommand
in classorg.infinispan.interceptors.DDAsyncInterceptor
-
getLog
protected org.infinispan.util.logging.Log getLog()
- Specified by:
getLog
in classorg.infinispan.interceptors.impl.BaseRpcInterceptor
-
-