Class BaseInvalidationInterceptor

  • All Implemented Interfaces:
    org.infinispan.commands.Visitor, org.infinispan.interceptors.AsyncInterceptor, org.infinispan.jmx.JmxStatisticsExposer
    Direct Known Subclasses:
    NonTxInvalidationInterceptor, TxInvalidationInterceptor

    public abstract class BaseInvalidationInterceptor
    extends org.infinispan.interceptors.impl.BaseRpcInterceptor
    implements org.infinispan.jmx.JmxStatisticsExposer
    • Field Summary

      Fields 
      Modifier and Type Field Description
      protected org.infinispan.Cache cache  
      protected org.infinispan.util.ByteString cacheName  
      protected org.infinispan.commands.CommandsFactory commandsFactory  
      protected org.infinispan.distribution.DistributionManager distributionManager  
      protected boolean statisticsEnabled  
      protected org.infinispan.remoting.rpc.RpcOptions syncRpcOptions  
      • Fields inherited from class org.infinispan.interceptors.impl.BaseRpcInterceptor

        componentRegistry, defaultSynchronous, rpcManager, trace
      • Fields inherited from class org.infinispan.interceptors.BaseAsyncInterceptor

        cacheConfiguration
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      long getInvalidations()  
      protected List<org.infinispan.remoting.transport.Address> getMembers()  
      boolean getStatisticsEnabled()  
      protected void incrementInvalidations()  
      protected boolean isPutForExternalRead​(org.infinispan.commands.FlagAffectedCommand command)  
      void resetStatistics()  
      void setStatisticsEnabled​(boolean enabled)  
      • Methods inherited from class org.infinispan.interceptors.impl.BaseRpcInterceptor

        getLog, init, isLocalModeForced, isSynchronous, shouldInvokeRemoteTxCommand, shouldTotalOrderRollbackBeInvokedRemotely, totalOrderPrepare, totalOrderTxCommit, totalOrderTxRollback, transactionRemotelyPrepared
      • Methods inherited from class org.infinispan.interceptors.DDAsyncInterceptor

        handleDefault, visitClearCommand, visitCommand, visitCommitCommand, visitComputeCommand, visitComputeIfAbsentCommand, visitDistributedExecuteCommand, visitEntrySetCommand, visitEvictCommand, visitGetAllCommand, visitGetCacheEntryCommand, visitGetKeysInGroupCommand, visitGetKeyValueCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitLockControlCommand, visitPrepareCommand, visitPutKeyValueCommand, visitPutMapCommand, visitReadOnlyKeyCommand, visitReadOnlyManyCommand, visitReadWriteKeyCommand, visitReadWriteKeyValueCommand, visitReadWriteManyCommand, visitReadWriteManyEntriesCommand, visitRemoveCommand, visitReplaceCommand, 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
    • Field Detail

      • commandsFactory

        protected org.infinispan.commands.CommandsFactory commandsFactory
      • distributionManager

        protected org.infinispan.distribution.DistributionManager distributionManager
      • cache

        protected org.infinispan.Cache cache
      • cacheName

        protected org.infinispan.util.ByteString cacheName
      • statisticsEnabled

        protected boolean statisticsEnabled
      • syncRpcOptions

        protected org.infinispan.remoting.rpc.RpcOptions syncRpcOptions
    • Constructor Detail

      • BaseInvalidationInterceptor

        public BaseInvalidationInterceptor()
    • Method Detail

      • resetStatistics

        public void resetStatistics()
        Specified by:
        resetStatistics in interface org.infinispan.jmx.JmxStatisticsExposer
      • getStatisticsEnabled

        public boolean getStatisticsEnabled()
        Specified by:
        getStatisticsEnabled in interface org.infinispan.jmx.JmxStatisticsExposer
      • setStatisticsEnabled

        public void setStatisticsEnabled​(boolean enabled)
        Specified by:
        setStatisticsEnabled in interface org.infinispan.jmx.JmxStatisticsExposer
      • getInvalidations

        public long getInvalidations()
      • incrementInvalidations

        protected void incrementInvalidations()
      • getMembers

        protected List<org.infinispan.remoting.transport.Address> getMembers()
      • isPutForExternalRead

        protected boolean isPutForExternalRead​(org.infinispan.commands.FlagAffectedCommand command)