org.hibernate.cache.infinispan.access

Class UnorderedDistributionInterceptor

java.lang.Object

org.infinispan.commands.AbstractVisitor

org.infinispan.interceptors.base.CommandInterceptor

org.infinispan.interceptors.base.BaseRpcInterceptor

org.infinispan.interceptors.ClusteringInterceptor

org.infinispan.interceptors.distribution.BaseDistributionInterceptor

org.infinispan.interceptors.distribution.NonTxDistributionInterceptor

org.hibernate.cache.infinispan.access.UnorderedDistributionInterceptor

All Implemented Interfaces:

org.infinispan.commands.Visitor

public class UnorderedDistributionInterceptor
extends org.infinispan.interceptors.distribution.NonTxDistributionInterceptor

Since the data handled in TombstoneCallInterceptor or VersionedCallInterceptor does not rely on the order how these are applied (the updates are commutative), this interceptor simply sends any command to all other owners without ordering them through primary owner. Note that LockingInterceptor is required in the stack as locking on backup is not guaranteed by primary owner.

Field Summary

Fields inherited from class org.infinispan.interceptors.distribution.BaseDistributionInterceptor

cdl, dm, isL1Enabled, rvrl

Fields inherited from class org.infinispan.interceptors.ClusteringInterceptor

cf, dataContainer, entryFactory, lockManager, stateTransferManager

Fields inherited from class org.infinispan.interceptors.base.BaseRpcInterceptor

defaultSynchronous, rpcManager

Fields inherited from class org.infinispan.interceptors.base.CommandInterceptor

cacheConfiguration

Constructor Summary

Constructors

Constructor and Description
UnorderedDistributionInterceptor()

Method Summary

Modifier and Type	Method and Description
void	inject(org.infinispan.distribution.DistributionManager distributionManager)
void	start()
java.lang.Object	visitPutKeyValueCommand(org.infinispan.context.InvocationContext ctx, org.infinispan.commands.write.PutKeyValueCommand command)

Methods inherited from class org.infinispan.interceptors.distribution.NonTxDistributionInterceptor

remoteGetBeforeWrite, visitGetCacheEntryCommand, visitGetKeyValueCommand, visitPutMapCommand, visitReadOnlyKeyCommand, visitReadOnlyManyCommand, visitReadWriteKeyCommand, visitReadWriteKeyValueCommand, visitReadWriteManyCommand, visitReadWriteManyEntriesCommand, visitRemoveCommand, visitReplaceCommand, visitWriteOnlyKeyCommand, visitWriteOnlyKeyValueCommand, visitWriteOnlyManyCommand, visitWriteOnlyManyEntriesCommand, writeNeedsRemoteValue

Methods inherited from class org.infinispan.interceptors.distribution.BaseDistributionInterceptor

configure, fetchValueLocallyIfAvailable, getLog, handleNonTxWriteCommand, injectDependencies, isValueAvailableLocally, readNeedsRemoteValue, retrieveFromRemoteSource, retrieveFromRemoteSources, valueIsMissing, visitClearCommand, visitGetAllCommand, visitGetKeysInGroupCommand

Methods inherited from class org.infinispan.interceptors.ClusteringInterceptor

injectDependencies

Methods inherited from class org.infinispan.interceptors.base.BaseRpcInterceptor

getSelfDeliverFilter, init, inject, isLocalModeForced, isSyncCommitPhase, isSynchronous, shouldInvokeRemoteTxCommand, shouldTotalOrderRollbackBeInvokedRemotely, totalOrderPrepare, totalOrderTxCommit, totalOrderTxRollback, transactionRemotelyPrepared

Methods inherited from class org.infinispan.interceptors.base.CommandInterceptor

getCacheWithFlags, getLockAcquisitionTimeout, getNext, handleDefault, hasNext, hasSkipLocking, injectConfiguration, invokeNextInterceptor, setNext

Methods inherited from class org.infinispan.commands.AbstractVisitor

visitApplyDeltaCommand, visitCollection, visitCommitCommand, visitDistributedExecuteCommand, visitEntrySetCommand, visitEvictCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitLockControlCommand, visitPrepareCommand, visitRollbackCommand, visitSizeCommand, visitUnknownCommand

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

UnorderedDistributionInterceptor

public UnorderedDistributionInterceptor()

Method Detail

inject

public void inject(org.infinispan.distribution.DistributionManager distributionManager)

start

public void start()

visitPutKeyValueCommand

public java.lang.Object visitPutKeyValueCommand(org.infinispan.context.InvocationContext ctx,
                                                org.infinispan.commands.write.PutKeyValueCommand command)
                                         throws java.lang.Throwable

Specified by:

visitPutKeyValueCommand in interface org.infinispan.commands.Visitor

Overrides:

visitPutKeyValueCommand in class org.infinispan.interceptors.distribution.NonTxDistributionInterceptor

Throws:

java.lang.Throwable