org.infinispan.interceptors.impl

Class NonTxIracRemoteSiteInterceptor

java.lang.Object

org.infinispan.interceptors.BaseAsyncInterceptor

org.infinispan.interceptors.DDAsyncInterceptor

org.infinispan.interceptors.impl.AbstractIracLocalSiteInterceptor

org.infinispan.interceptors.impl.AbstractIracRemoteSiteInterceptor

org.infinispan.interceptors.impl.NonTxIracRemoteSiteInterceptor

All Implemented Interfaces:

Visitor, AsyncInterceptor

public class NonTxIracRemoteSiteInterceptor
extends AbstractIracRemoteSiteInterceptor

Interceptor for non-transactional caches to handle updates from remote sites. Remote sites only send PutKeyValueCommand or RemoveCommand.

Since:

11.0

Author:

Pedro Ruivo

Field Summary

Fields inherited from class org.infinispan.interceptors.BaseAsyncInterceptor

cacheConfiguration

Constructor Summary

Constructors

Constructor and Description
NonTxIracRemoteSiteInterceptor()

Method Summary

Modifier and Type	Method and Description
Object	visitPutKeyValueCommand(InvocationContext ctx, PutKeyValueCommand command)
Object	visitRemoveCommand(InvocationContext ctx, RemoveCommand command)

Methods inherited from class org.infinispan.interceptors.impl.AbstractIracRemoteSiteInterceptor

setIracMetadataForOwner, validateOnPrimary

Methods inherited from class org.infinispan.interceptors.impl.AbstractIracLocalSiteInterceptor

getCacheTopology, getDistributionInfo, getDistributionInfo, getOwnership, getOwnership, getSegment, isIracState, isNormalWriteCommand, isPrimaryOwner, isWriteOwner, setIracMetadata, setMetadataToCacheEntry, streamKeysFromCommand, streamKeysFromModifications, streamKeysFromModifications

Methods inherited from class org.infinispan.interceptors.DDAsyncInterceptor

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

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

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

visitRemoveExpiredCommand

Constructor Detail

NonTxIracRemoteSiteInterceptor

public NonTxIracRemoteSiteInterceptor()

Method Detail

visitPutKeyValueCommand

public Object visitPutKeyValueCommand(InvocationContext ctx,
                                      PutKeyValueCommand command)

Specified by:

visitPutKeyValueCommand in interface Visitor

Overrides:

visitPutKeyValueCommand in class DDAsyncInterceptor

visitRemoveCommand

public Object visitRemoveCommand(InvocationContext ctx,
                                 RemoveCommand command)

Specified by:

visitRemoveCommand in interface Visitor

Overrides:

visitRemoveCommand in class DDAsyncInterceptor