org.hibernate.cache.infinispan.access

Class BaseInvalidationInterceptor

java.lang.Object

org.infinispan.commands.AbstractVisitor

org.infinispan.interceptors.base.CommandInterceptor

org.infinispan.interceptors.base.BaseRpcInterceptor

org.hibernate.cache.infinispan.access.BaseInvalidationInterceptor

All Implemented Interfaces:

org.infinispan.commands.Visitor, org.infinispan.jmx.JmxStatisticsExposer

Direct Known Subclasses:

NonTxInvalidationInterceptor, TxInvalidationInterceptor

public abstract class BaseInvalidationInterceptor
extends org.infinispan.interceptors.base.BaseRpcInterceptor
implements org.infinispan.jmx.JmxStatisticsExposer

Field Summary

Fields

Modifier and Type	Field and Description
protected org.infinispan.remoting.rpc.RpcOptions	asyncRpcOptions
protected java.lang.String	cacheName
protected org.infinispan.commands.CommandsFactory	commandsFactory
protected org.infinispan.statetransfer.StateTransferManager	stateTransferManager
protected boolean	statisticsEnabled
protected org.infinispan.remoting.rpc.RpcOptions	syncRpcOptions

Fields inherited from class org.infinispan.interceptors.base.BaseRpcInterceptor

defaultSynchronous, rpcManager, trace

Fields inherited from class org.infinispan.interceptors.base.CommandInterceptor

cacheConfiguration

Constructor Summary

Constructors

Constructor and Description
BaseInvalidationInterceptor()

Method Summary

Modifier and Type	Method and Description
long	getInvalidations()
protected java.util.List<org.infinispan.remoting.transport.Address>	getMembers()
boolean	getStatisticsEnabled()
protected void	incrementInvalidations()
void	injectDependencies(org.infinispan.commands.CommandsFactory commandsFactory, org.infinispan.statetransfer.StateTransferManager stateTransferManager, org.infinispan.Cache cache)
protected boolean	isPutForExternalRead(org.infinispan.commands.FlagAffectedCommand command)
void	resetStatistics()
void	setStatisticsEnabled(boolean enabled)

Methods inherited from class org.infinispan.interceptors.base.BaseRpcInterceptor

getSelfDeliverFilter, init, inject, isLocalModeForced, isSyncCommitPhase, isSynchronous, shouldInvokeRemoteTxCommand, shouldTotalOrderRollbackBeInvokedRemotely, totalOrderPrepare, totalOrderTxCommit, totalOrderTxRollback, transactionRemotelyPrepared

Methods inherited from class org.infinispan.interceptors.base.CommandInterceptor

getCacheWithFlags, getLockAcquisitionTimeout, getLog, getNext, handleDefault, hasNext, hasSkipLocking, injectConfiguration, invokeNextInterceptor, setNext

Methods inherited from class org.infinispan.commands.AbstractVisitor

visitApplyDeltaCommand, visitClearCommand, visitCollection, visitCommitCommand, 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 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

commandsFactory

protected org.infinispan.commands.CommandsFactory commandsFactory

stateTransferManager

protected org.infinispan.statetransfer.StateTransferManager stateTransferManager

cacheName

protected java.lang.String cacheName

statisticsEnabled

protected boolean statisticsEnabled

syncRpcOptions

protected org.infinispan.remoting.rpc.RpcOptions syncRpcOptions

asyncRpcOptions

protected org.infinispan.remoting.rpc.RpcOptions asyncRpcOptions

Constructor Detail

BaseInvalidationInterceptor

public BaseInvalidationInterceptor()

Method Detail

injectDependencies

public void injectDependencies(org.infinispan.commands.CommandsFactory commandsFactory,
                               org.infinispan.statetransfer.StateTransferManager stateTransferManager,
                               org.infinispan.Cache cache)

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 java.util.List<org.infinispan.remoting.transport.Address> getMembers()

isPutForExternalRead

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