Class TotalOrderDistributionInterceptor
- java.lang.Object
-
- org.infinispan.interceptors.BaseAsyncInterceptor
-
- org.infinispan.interceptors.DDAsyncInterceptor
-
- org.infinispan.interceptors.impl.BaseRpcInterceptor
-
- org.infinispan.interceptors.impl.ClusteringInterceptor
-
- org.infinispan.interceptors.distribution.BaseDistributionInterceptor
-
- org.infinispan.interceptors.distribution.TxDistributionInterceptor
-
- org.infinispan.interceptors.totalorder.TotalOrderDistributionInterceptor
-
- All Implemented Interfaces:
org.infinispan.commands.Visitor
,AsyncInterceptor
@Deprecated public class TotalOrderDistributionInterceptor extends TxDistributionInterceptor
Deprecated.since 10.0. Total Order will be removed.This interceptor handles distribution of entries across a cluster, as well as transparent lookup, when the total order based protocol is enabled- Author:
- Pedro Ruivo
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.infinispan.interceptors.distribution.BaseDistributionInterceptor
BaseDistributionInterceptor.ReadManyCommandHelper<C extends org.infinispan.commands.VisitableCommand>, BaseDistributionInterceptor.ReadOnlyManyHelper
-
-
Field Summary
-
Fields inherited from class org.infinispan.interceptors.distribution.BaseDistributionInterceptor
expirationManager, isL1Enabled, isReplicated, keyPartitioner, rvrl, timeService
-
Fields inherited from class org.infinispan.interceptors.impl.ClusteringInterceptor
cf, dataContainer, distributionManager, entryFactory, lockManager
-
Fields inherited from class org.infinispan.interceptors.impl.BaseRpcInterceptor
componentRegistry, defaultSynchronous, rpcManager
-
Fields inherited from class org.infinispan.interceptors.BaseAsyncInterceptor
cacheConfiguration
-
-
Constructor Summary
Constructors Constructor Description TotalOrderDistributionInterceptor()
Deprecated.
-
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description protected LocalizedCacheTopology
checkTopologyId(org.infinispan.commands.TopologyAffectedCommand command)
Deprecated.protected org.infinispan.util.logging.Log
getLog()
Deprecated.protected java.util.concurrent.CompletionStage<java.lang.Object>
prepareOnAffectedNodes(org.infinispan.context.impl.TxInvocationContext<?> ctx, org.infinispan.commands.tx.PrepareCommand command, java.util.Collection<Address> recipients)
Deprecated.void
start()
Deprecated.java.lang.Object
visitCommitCommand(org.infinispan.context.impl.TxInvocationContext ctx, org.infinispan.commands.tx.CommitCommand command)
Deprecated.java.lang.Object
visitRollbackCommand(org.infinispan.context.impl.TxInvocationContext ctx, org.infinispan.commands.tx.RollbackCommand command)
Deprecated.-
Methods inherited from class org.infinispan.interceptors.distribution.TxDistributionInterceptor
checkTxCommandResponses, configure, handleRemotelyRetrievedKeys, handleTxFunctionalCommand, handleTxWriteManyCommand, handleTxWriteManyEntriesCommand, remoteGetSingleKey, remoteReadOnlyCommand, visitComputeCommand, visitComputeIfAbsentCommand, visitLockControlCommand, visitPrepareCommand, visitPutKeyValueCommand, visitPutMapCommand, visitReadOnlyManyCommand, visitReadWriteKeyCommand, visitReadWriteKeyValueCommand, visitReadWriteManyCommand, visitReadWriteManyEntriesCommand, visitRemoveCommand, visitRemoveExpiredCommand, visitReplaceCommand, visitWriteOnlyKeyCommand, visitWriteOnlyKeyValueCommand, visitWriteOnlyManyCommand, visitWriteOnlyManyEntriesCommand
-
Methods inherited from class org.infinispan.interceptors.distribution.BaseDistributionInterceptor
handleFunctionalReadManyCommand, handleNonTxWriteCommand, invokeRemotely, invokeRemoveExpiredCommand, readNeedsRemoteValue, remoteGetMany, retrieveDistributionInfo, unwrapFunctionalManyResultOnOrigin, unwrapFunctionalResultOnOrigin, visitClearCommand, visitGetAllCommand, visitGetCacheEntryCommand, visitGetKeysInGroupCommand, visitGetKeyValueCommand, visitReadOnlyKeyCommand, wrapFunctionalManyResultOnNonOrigin, wrapFunctionalResultOnNonOriginOnReturn, wrapRemoteEntry
-
Methods inherited from class org.infinispan.interceptors.impl.ClusteringInterceptor
getSuccessfulResponseOrFail, unexpected
-
Methods inherited from class org.infinispan.interceptors.impl.BaseRpcInterceptor
init, isLocalModeForced, isSynchronous, shouldInvokeRemoteTxCommand, shouldTotalOrderRollbackBeInvokedRemotely, totalOrderPrepare, totalOrderTxCommit, totalOrderTxRollback, transactionRemotelyPrepared
-
Methods inherited from class org.infinispan.interceptors.DDAsyncInterceptor
handleDefault, visitCommand, visitEntrySetCommand, visitEvictCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitSizeCommand, visitUnknownCommand
-
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
-
-
-
-
Method Detail
-
start
public void start()
Deprecated.
-
visitRollbackCommand
public java.lang.Object visitRollbackCommand(org.infinispan.context.impl.TxInvocationContext ctx, org.infinispan.commands.tx.RollbackCommand command) throws java.lang.Throwable
Deprecated.- Specified by:
visitRollbackCommand
in interfaceorg.infinispan.commands.Visitor
- Overrides:
visitRollbackCommand
in classTxDistributionInterceptor
- Throws:
java.lang.Throwable
-
visitCommitCommand
public java.lang.Object visitCommitCommand(org.infinispan.context.impl.TxInvocationContext ctx, org.infinispan.commands.tx.CommitCommand command) throws java.lang.Throwable
Deprecated.- Specified by:
visitCommitCommand
in interfaceorg.infinispan.commands.Visitor
- Overrides:
visitCommitCommand
in classTxDistributionInterceptor
- Throws:
java.lang.Throwable
-
prepareOnAffectedNodes
protected java.util.concurrent.CompletionStage<java.lang.Object> prepareOnAffectedNodes(org.infinispan.context.impl.TxInvocationContext<?> ctx, org.infinispan.commands.tx.PrepareCommand command, java.util.Collection<Address> recipients)
Deprecated.- Overrides:
prepareOnAffectedNodes
in classTxDistributionInterceptor
-
checkTopologyId
protected LocalizedCacheTopology checkTopologyId(org.infinispan.commands.TopologyAffectedCommand command)
Deprecated.- Overrides:
checkTopologyId
in classBaseDistributionInterceptor
-
getLog
protected org.infinispan.util.logging.Log getLog()
Deprecated.- Overrides:
getLog
in classBaseDistributionInterceptor
-
-