Class OptimisticLockingInterceptor
- java.lang.Object
-
- org.infinispan.interceptors.BaseAsyncInterceptor
-
- org.infinispan.interceptors.DDAsyncInterceptor
-
- org.infinispan.interceptors.locking.AbstractLockingInterceptor
-
- org.infinispan.interceptors.locking.AbstractTxLockingInterceptor
-
- org.infinispan.interceptors.locking.OptimisticLockingInterceptor
-
- All Implemented Interfaces:
org.infinispan.commands.Visitor
,AsyncInterceptor
public class OptimisticLockingInterceptor extends AbstractTxLockingInterceptor
Locking interceptor to be used by optimistic transactional caches.- Author:
- Mircea Markus
-
-
Field Summary
-
Fields inherited from class org.infinispan.interceptors.locking.AbstractLockingInterceptor
cdl, invalidationMode, lockManager
-
Fields inherited from class org.infinispan.interceptors.BaseAsyncInterceptor
cacheConfiguration
-
-
Constructor Summary
Constructors Constructor Description OptimisticLockingInterceptor()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected org.infinispan.util.logging.Log
getLog()
protected java.lang.Object
handleReadManyCommand(InvocationContext ctx, org.infinispan.commands.FlagAffectedCommand command, java.util.Collection<?> keys)
protected <K> java.lang.Object
handleWriteManyCommand(InvocationContext ctx, org.infinispan.commands.write.WriteCommand command, java.util.Collection<K> keys, boolean forwarded)
protected java.lang.Object
visitDataReadCommand(InvocationContext ctx, org.infinispan.commands.DataCommand command)
protected java.lang.Object
visitDataWriteCommand(InvocationContext ctx, org.infinispan.commands.write.DataWriteCommand command)
java.lang.Object
visitLockControlCommand(org.infinispan.context.impl.TxInvocationContext ctx, org.infinispan.commands.control.LockControlCommand command)
java.lang.Object
visitPrepareCommand(org.infinispan.context.impl.TxInvocationContext ctx, org.infinispan.commands.tx.PrepareCommand command)
-
Methods inherited from class org.infinispan.interceptors.locking.AbstractTxLockingInterceptor
visitCommitCommand, visitRollbackCommand
-
Methods inherited from class org.infinispan.interceptors.locking.AbstractLockingInterceptor
getLockTimeoutMillis, lockAndRecord, start, visitClearCommand, visitComputeCommand, visitComputeIfAbsentCommand, visitGetAllCommand, visitGetCacheEntryCommand, visitGetKeyValueCommand, visitInvalidateCommand, visitInvalidateL1Command, visitPutKeyValueCommand, visitPutMapCommand, visitReadOnlyKeyCommand, visitReadOnlyManyCommand, visitReadWriteKeyCommand, visitReadWriteKeyValueCommand, visitReadWriteManyCommand, visitReadWriteManyEntriesCommand, visitRemoveCommand, visitReplaceCommand, visitWriteOnlyKeyCommand, visitWriteOnlyKeyValueCommand, visitWriteOnlyManyCommand, visitWriteOnlyManyEntriesCommand
-
Methods inherited from class org.infinispan.interceptors.DDAsyncInterceptor
handleDefault, visitCommand, visitEntrySetCommand, visitEvictCommand, visitGetKeysInGroupCommand, visitKeySetCommand, visitSizeCommand, visitUnknownCommand
-
Methods inherited from class org.infinispan.interceptors.BaseAsyncInterceptor
asyncInvokeNext, asyncInvokeNext, asyncInvokeNext, asyncValue, delayedNull, delayedValue, delayedValue, invokeNext, invokeNextAndExceptionally, invokeNextAndFinally, invokeNextAndHandle, invokeNextThenAccept, invokeNextThenApply, isSuccessfullyDone, makeStage, setNextInterceptor, valueOrException
-
-
-
-
Method Detail
-
getLog
protected org.infinispan.util.logging.Log getLog()
- Specified by:
getLog
in classAbstractLockingInterceptor
-
visitPrepareCommand
public java.lang.Object visitPrepareCommand(org.infinispan.context.impl.TxInvocationContext ctx, org.infinispan.commands.tx.PrepareCommand command) throws java.lang.Throwable
- Specified by:
visitPrepareCommand
in interfaceorg.infinispan.commands.Visitor
- Overrides:
visitPrepareCommand
in classDDAsyncInterceptor
- Throws:
java.lang.Throwable
-
visitDataReadCommand
protected java.lang.Object visitDataReadCommand(InvocationContext ctx, org.infinispan.commands.DataCommand command) throws java.lang.Throwable
- Specified by:
visitDataReadCommand
in classAbstractLockingInterceptor
- Throws:
java.lang.Throwable
-
visitDataWriteCommand
protected java.lang.Object visitDataWriteCommand(InvocationContext ctx, org.infinispan.commands.write.DataWriteCommand command) throws java.lang.Throwable
- Specified by:
visitDataWriteCommand
in classAbstractLockingInterceptor
- Throws:
java.lang.Throwable
-
handleReadManyCommand
protected java.lang.Object handleReadManyCommand(InvocationContext ctx, org.infinispan.commands.FlagAffectedCommand command, java.util.Collection<?> keys)
- Overrides:
handleReadManyCommand
in classAbstractTxLockingInterceptor
-
handleWriteManyCommand
protected <K> java.lang.Object handleWriteManyCommand(InvocationContext ctx, org.infinispan.commands.write.WriteCommand command, java.util.Collection<K> keys, boolean forwarded) throws java.lang.Throwable
- Specified by:
handleWriteManyCommand
in classAbstractLockingInterceptor
- Throws:
java.lang.Throwable
-
visitLockControlCommand
public java.lang.Object visitLockControlCommand(org.infinispan.context.impl.TxInvocationContext ctx, org.infinispan.commands.control.LockControlCommand command) throws java.lang.Throwable
- Specified by:
visitLockControlCommand
in interfaceorg.infinispan.commands.Visitor
- Overrides:
visitLockControlCommand
in classDDAsyncInterceptor
- Throws:
java.lang.Throwable
-
-