public abstract class AbstractIracRemoteSiteInterceptor extends AbstractIracLocalSiteInterceptor
This class contains only the common code and it is always present in the AsyncInterceptorChain
because the
cache has no knowledge if it is a backup from others site or not.
cacheConfiguration
Constructor and Description |
---|
AbstractIracRemoteSiteInterceptor() |
Modifier and Type | Method and Description |
---|---|
protected void |
setIracMetadataForOwner(InvocationContext ctx,
DataWriteCommand command,
Object rv)
Invoked by backup owners, it make sure the entry has the same version as set by the primary owner.
|
protected void |
validateOnPrimary(InvocationContext ctx,
DataWriteCommand command,
Object rv)
Invoked on the primary owner, it validates if the remote site update is valid or not.
|
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, visitPutKeyValueCommand, visitPutMapCommand, visitReadOnlyKeyCommand, visitReadOnlyManyCommand, visitReadWriteKeyCommand, visitReadWriteKeyValueCommand, visitReadWriteManyCommand, visitReadWriteManyEntriesCommand, visitRemoveCommand, 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
protected void validateOnPrimary(InvocationContext ctx, DataWriteCommand command, Object rv)
It also performs a conflict resolution if a conflict is found.
protected void setIracMetadataForOwner(InvocationContext ctx, DataWriteCommand command, Object rv)
Copyright © 2021 JBoss by Red Hat. All rights reserved.