Class BaseInvalidationInterceptor
- java.lang.Object
-
- org.infinispan.interceptors.BaseAsyncInterceptor
-
- org.infinispan.interceptors.DDAsyncInterceptor
-
- org.infinispan.interceptors.impl.BaseRpcInterceptor
-
- org.infinispan.hibernate.cache.commons.access.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
-
Constructor Summary
Constructors Constructor Description BaseInvalidationInterceptor()
-
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
-
-
-
-
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
-
-
Method Detail
-
resetStatistics
public void resetStatistics()
- Specified by:
resetStatistics
in interfaceorg.infinispan.jmx.JmxStatisticsExposer
-
getStatisticsEnabled
public boolean getStatisticsEnabled()
- Specified by:
getStatisticsEnabled
in interfaceorg.infinispan.jmx.JmxStatisticsExposer
-
setStatisticsEnabled
public void setStatisticsEnabled(boolean enabled)
- Specified by:
setStatisticsEnabled
in interfaceorg.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)
-
-