public class CacheWriterInterceptor extends JmxStatsCommandInterceptor
Modifier and Type | Class and Description |
---|---|
class |
CacheWriterInterceptor.Updater |
Modifier and Type | Field and Description |
---|---|
protected boolean |
enabled |
protected PersistenceManager |
persistenceManager |
cacheConfiguration
Constructor and Description |
---|
CacheWriterInterceptor() |
checkStatisticsUsed, getStatisticsEnabled, setStatisticsEnabled
getLockAcquisitionTimeout, getNext, handleDefault, hasNext, hasSkipLocking, injectConfiguration, invokeNextInterceptor, setNext
visitApplyDeltaCommand, visitCollection, visitDistributedExecuteCommand, visitEntrySetCommand, visitEvictCommand, visitGetKeyValueCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitLockControlCommand, visitRollbackCommand, visitSizeCommand, visitUnknownCommand, visitValuesCommand
protected PersistenceManager persistenceManager
protected volatile boolean enabled
protected Log getLog()
getLog
in class CommandInterceptor
protected void init(PersistenceManager pm, InternalEntryFactory entryFactory, TransactionManager transactionManager, StreamingMarshaller marshaller)
protected void start()
public Object visitCommitCommand(TxInvocationContext ctx, CommitCommand command) throws Throwable
visitCommitCommand
in interface Visitor
visitCommitCommand
in class AbstractVisitor
Throwable
public Object visitPrepareCommand(TxInvocationContext ctx, PrepareCommand command) throws Throwable
visitPrepareCommand
in interface Visitor
visitPrepareCommand
in class AbstractVisitor
Throwable
protected void commitCommand(TxInvocationContext ctx) throws Throwable
Throwable
public Object visitRemoveCommand(InvocationContext ctx, RemoveCommand command) throws Throwable
visitRemoveCommand
in interface Visitor
visitRemoveCommand
in class AbstractVisitor
Throwable
public Object visitClearCommand(InvocationContext ctx, ClearCommand command) throws Throwable
visitClearCommand
in interface Visitor
visitClearCommand
in class AbstractVisitor
Throwable
public Object visitPutKeyValueCommand(InvocationContext ctx, PutKeyValueCommand command) throws Throwable
visitPutKeyValueCommand
in interface Visitor
visitPutKeyValueCommand
in class AbstractVisitor
Throwable
public Object visitReplaceCommand(InvocationContext ctx, ReplaceCommand command) throws Throwable
visitReplaceCommand
in interface Visitor
visitReplaceCommand
in class AbstractVisitor
Throwable
public Object visitPutMapCommand(InvocationContext ctx, PutMapCommand command) throws Throwable
visitPutMapCommand
in interface Visitor
visitPutMapCommand
in class AbstractVisitor
Throwable
protected final void store(TxInvocationContext ctx) throws Throwable
Throwable
protected boolean isStoreEnabled()
protected boolean isStoreEnabled(FlagAffectedCommand command)
protected boolean isProperWriter(InvocationContext ctx, FlagAffectedCommand command, Object key)
public void resetStatistics()
JmxStatsCommandInterceptor
resetStatistics
in interface JmxStatisticsExposer
resetStatistics
in class JmxStatsCommandInterceptor
public long getWritesToTheStores()
protected boolean skipSharedStores(InvocationContext ctx, Object key, FlagAffectedCommand command)
public void disableInterceptor()
Copyright © 2014 JBoss, a division of Red Hat. All Rights Reserved.