public class PessimisticTxIracRemoteSiteInterceptor extends AbstractIracRemoteSiteInterceptor
Since the pessimistic transactions commits in one phase and the version need to be validated after the lock is acquired, the other site update must be "replayed" in the primary owner.
cacheConfiguration
Constructor and Description |
---|
PessimisticTxIracRemoteSiteInterceptor() |
Modifier and Type | Method and Description |
---|---|
Object |
visitPutKeyValueCommand(InvocationContext ctx,
PutKeyValueCommand command) |
Object |
visitRemoveCommand(InvocationContext ctx,
RemoveCommand command) |
setIracMetadataForOwner, validateOnPrimary
getCacheTopology, getDistributionInfo, getDistributionInfo, getOwnership, getOwnership, getSegment, isIracState, isNormalWriteCommand, isPrimaryOwner, isWriteOwner, setIracMetadata, setMetadataToCacheEntry, streamKeysFromCommand, streamKeysFromModifications, streamKeysFromModifications
handleDefault, visitClearCommand, visitCommand, visitCommitCommand, visitComputeCommand, visitComputeIfAbsentCommand, visitEntrySetCommand, visitEvictCommand, visitGetAllCommand, visitGetCacheEntryCommand, visitGetKeysInGroupCommand, visitGetKeyValueCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitLockControlCommand, visitPrepareCommand, visitPutMapCommand, visitReadOnlyKeyCommand, visitReadOnlyManyCommand, visitReadWriteKeyCommand, visitReadWriteKeyValueCommand, visitReadWriteManyCommand, visitReadWriteManyEntriesCommand, visitReplaceCommand, visitRollbackCommand, visitSizeCommand, visitUnknownCommand, visitWriteOnlyKeyCommand, visitWriteOnlyKeyValueCommand, visitWriteOnlyManyCommand, visitWriteOnlyManyEntriesCommand
asyncInvokeNext, asyncInvokeNext, asyncInvokeNext, asyncValue, delayedNull, delayedValue, delayedValue, invokeNext, invokeNextAndExceptionally, invokeNextAndFinally, invokeNextAndHandle, invokeNextThenAccept, invokeNextThenApply, isSuccessfullyDone, makeStage, setNextInterceptor, valueOrException
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
visitRemoveExpiredCommand
public PessimisticTxIracRemoteSiteInterceptor()
public Object visitPutKeyValueCommand(InvocationContext ctx, PutKeyValueCommand command)
visitPutKeyValueCommand
in interface Visitor
visitPutKeyValueCommand
in class DDAsyncInterceptor
public Object visitRemoveCommand(InvocationContext ctx, RemoveCommand command)
visitRemoveCommand
in interface Visitor
visitRemoveCommand
in class DDAsyncInterceptor
Copyright © 2021 JBoss by Red Hat. All rights reserved.