Class 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
    • 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.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
      • Methods inherited from interface org.infinispan.commands.Visitor

        visitApplyDeltaCommand, visitRemoveExpiredCommand
    • Constructor Detail

      • NonTxInvalidationInterceptor

        public NonTxInvalidationInterceptor()
    • Method Detail

      • visitPutKeyValueCommand

        public Object visitPutKeyValueCommand​(org.infinispan.context.InvocationContext ctx,
                                              org.infinispan.commands.write.PutKeyValueCommand command)
        Specified by:
        visitPutKeyValueCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitPutKeyValueCommand in class org.infinispan.interceptors.DDAsyncInterceptor
      • visitReplaceCommand

        public Object visitReplaceCommand​(org.infinispan.context.InvocationContext ctx,
                                          org.infinispan.commands.write.ReplaceCommand command)
        Specified by:
        visitReplaceCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitReplaceCommand in class org.infinispan.interceptors.DDAsyncInterceptor
      • visitRemoveCommand

        public Object visitRemoveCommand​(org.infinispan.context.InvocationContext ctx,
                                         org.infinispan.commands.write.RemoveCommand command)
        Specified by:
        visitRemoveCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitRemoveCommand in class org.infinispan.interceptors.DDAsyncInterceptor
      • visitClearCommand

        public Object visitClearCommand​(org.infinispan.context.InvocationContext ctx,
                                        org.infinispan.commands.write.ClearCommand command)
        Specified by:
        visitClearCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitClearCommand in class org.infinispan.interceptors.DDAsyncInterceptor
      • visitPutMapCommand

        public Object visitPutMapCommand​(org.infinispan.context.InvocationContext ctx,
                                         org.infinispan.commands.write.PutMapCommand command)
        Specified by:
        visitPutMapCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitPutMapCommand in class org.infinispan.interceptors.DDAsyncInterceptor
      • getLog

        protected org.infinispan.util.logging.Log getLog()
        Specified by:
        getLog in class org.infinispan.interceptors.impl.BaseRpcInterceptor