Class TotalOrderVersionedEntryWrappingInterceptor
- java.lang.Object
-
- org.infinispan.interceptors.BaseAsyncInterceptor
-
- org.infinispan.interceptors.DDAsyncInterceptor
-
- org.infinispan.interceptors.impl.EntryWrappingInterceptor
-
- org.infinispan.interceptors.impl.VersionedEntryWrappingInterceptor
-
- org.infinispan.interceptors.totalorder.TotalOrderVersionedEntryWrappingInterceptor
-
- All Implemented Interfaces:
Visitor
,AsyncInterceptor
public class TotalOrderVersionedEntryWrappingInterceptor extends org.infinispan.interceptors.impl.VersionedEntryWrappingInterceptor
Wrapping Interceptor for Total Order protocol when versions are needed- Author:
- Mircea.Markus@jboss.com, Pedro Ruivo
-
-
Field Summary
-
Fields inherited from class org.infinispan.interceptors.impl.VersionedEntryWrappingInterceptor
versionGenerator
-
Fields inherited from class org.infinispan.interceptors.impl.EntryWrappingInterceptor
cdl, distributionManager
-
Fields inherited from class org.infinispan.interceptors.BaseAsyncInterceptor
cacheConfiguration
-
-
Constructor Summary
Constructors Constructor Description TotalOrderVersionedEntryWrappingInterceptor()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
commitContextEntry(CacheEntry entry, InvocationContext ctx, FlagAffectedCommand command, Flag stateTransferFlag, boolean l1Invalidation)
Object
visitCommitCommand(org.infinispan.context.impl.TxInvocationContext ctx, CommitCommand command)
Object
visitPrepareCommand(org.infinispan.context.impl.TxInvocationContext ctx, PrepareCommand command)
-
Methods inherited from class org.infinispan.interceptors.impl.EntryWrappingInterceptor
canRead, canReadKey, commitContextEntries, setSkipRemoteGetsAndInvokeNextForDataCommand, setSkipRemoteGetsAndInvokeNextForManyEntriesCommand, shouldCommitDuringPrepare, start, visitClearCommand, visitComputeCommand, visitComputeIfAbsentCommand, visitEvictCommand, visitGetAllCommand, visitGetCacheEntryCommand, visitGetKeysInGroupCommand, visitGetKeyValueCommand, visitInvalidateCommand, visitInvalidateL1Command, visitPutKeyValueCommand, visitPutMapCommand, visitReadOnlyKeyCommand, visitReadOnlyManyCommand, visitReadWriteKeyCommand, visitReadWriteKeyValueCommand, visitReadWriteManyCommand, visitReadWriteManyEntriesCommand, visitRemoveCommand, visitRemoveExpiredCommand, visitReplaceCommand, visitWriteOnlyKeyCommand, visitWriteOnlyKeyValueCommand, visitWriteOnlyManyCommand, visitWriteOnlyManyEntriesCommand, wrapEntriesForPrepareAndApply
-
Methods inherited from class org.infinispan.interceptors.DDAsyncInterceptor
handleDefault, visitCommand, visitDistributedExecuteCommand, visitEntrySetCommand, visitKeySetCommand, visitLockControlCommand, visitRollbackCommand, visitSizeCommand, visitUnknownCommand
-
Methods inherited from class org.infinispan.interceptors.BaseAsyncInterceptor
asyncInvokeNext, asyncInvokeNext, asyncInvokeNext, asyncValue, invokeNext, invokeNextAndExceptionally, invokeNextAndFinally, invokeNextAndHandle, invokeNextThenAccept, invokeNextThenApply, isSuccessfullyDone, makeStage, setNextInterceptor, valueOrException
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.infinispan.commands.Visitor
visitApplyDeltaCommand
-
-
-
-
Method Detail
-
visitPrepareCommand
public final Object visitPrepareCommand(org.infinispan.context.impl.TxInvocationContext ctx, PrepareCommand command) throws Throwable
- Specified by:
visitPrepareCommand
in interfaceVisitor
- Overrides:
visitPrepareCommand
in classorg.infinispan.interceptors.impl.VersionedEntryWrappingInterceptor
- Throws:
Throwable
-
visitCommitCommand
public Object visitCommitCommand(org.infinispan.context.impl.TxInvocationContext ctx, CommitCommand command) throws Throwable
- Specified by:
visitCommitCommand
in interfaceVisitor
- Overrides:
visitCommitCommand
in classorg.infinispan.interceptors.impl.VersionedEntryWrappingInterceptor
- Throws:
Throwable
-
commitContextEntry
protected void commitContextEntry(CacheEntry entry, InvocationContext ctx, FlagAffectedCommand command, Flag stateTransferFlag, boolean l1Invalidation)
- Overrides:
commitContextEntry
in classorg.infinispan.interceptors.impl.VersionedEntryWrappingInterceptor
-
-