org.infinispan.interceptors.distribution

Class TxDistributionInterceptor

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.TxDistributionInterceptor

All Implemented Interfaces:

Visitor

Direct Known Subclasses:

TotalOrderDistributionInterceptor, VersionedDistributionInterceptor

Deprecated.

Since 8.2, no longer public API.

@Deprecated
public class TxDistributionInterceptor
extends BaseDistributionInterceptor

Handles the distribution of the transactional caches.

Author:

Mircea Markus

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
TxDistributionInterceptor() Deprecated.

Method Summary

Modifier and Type	Method and Description
protected void	checkTxCommandResponses(Map<Address,Response> responseMap, TransactionBoundaryCommand command, LocalTxInvocationContext context, Collection<Address> recipients) Deprecated.
protected RpcOptions	createPrepareRpcOptions() Deprecated.
void	inject(PartitionHandlingManager partitionHandlingManager) Deprecated.
protected void	prepareOnAffectedNodes(TxInvocationContext<?> ctx, PrepareCommand command, Collection<Address> recipients) Deprecated.
protected InternalCacheEntry	remoteGet(InvocationContext ctx, Object key, boolean isWrite, FlagAffectedCommand command) Deprecated.
protected void	remoteGetBeforeWrite(InvocationContext ctx, WriteCommand command, Object key) Deprecated.
void	start() Deprecated.
Object	visitCommitCommand(TxInvocationContext ctx, CommitCommand command) Deprecated.
Object	visitGetCacheEntryCommand(InvocationContext ctx, GetCacheEntryCommand command) Deprecated.
Object	visitGetKeyValueCommand(InvocationContext ctx, GetKeyValueCommand command) Deprecated.
Object	visitLockControlCommand(TxInvocationContext ctx, LockControlCommand command) Deprecated.
Object	visitPrepareCommand(TxInvocationContext ctx, PrepareCommand command) Deprecated.
Object	visitPutKeyValueCommand(InvocationContext ctx, PutKeyValueCommand command) Deprecated.
Object	visitPutMapCommand(InvocationContext ctx, PutMapCommand command) Deprecated.
Object	visitRemoveCommand(InvocationContext ctx, RemoveCommand command) Deprecated.
Object	visitReplaceCommand(InvocationContext ctx, ReplaceCommand command) Deprecated.
Object	visitRollbackCommand(TxInvocationContext ctx, RollbackCommand command) Deprecated.
protected boolean	writeNeedsRemoteValue(InvocationContext ctx, WriteCommand command, Object key) Deprecated.

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

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

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, visitDistributedExecuteCommand, visitEntrySetCommand, visitEvictCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitReadOnlyKeyCommand, visitReadWriteKeyCommand, visitReadWriteKeyValueCommand, visitReadWriteManyCommand, visitReadWriteManyEntriesCommand, visitSizeCommand, visitUnknownCommand, visitWriteOnlyKeyCommand, visitWriteOnlyKeyValueCommand, visitWriteOnlyManyCommand, visitWriteOnlyManyEntriesCommand

Methods inherited from class java.lang.Object

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

Constructor Detail

TxDistributionInterceptor

public TxDistributionInterceptor()

Deprecated.

Method Detail

inject

public void inject(PartitionHandlingManager partitionHandlingManager)

Deprecated.

start

public void start()

Deprecated.

visitReplaceCommand

public Object visitReplaceCommand(InvocationContext ctx,
                                  ReplaceCommand command)
                           throws Throwable

Deprecated.

Specified by:

visitReplaceCommand in interface Visitor

Overrides:

visitReplaceCommand in class AbstractVisitor

Throws:

Throwable

visitRemoveCommand

public Object visitRemoveCommand(InvocationContext ctx,
                                 RemoveCommand command)
                          throws Throwable

Deprecated.

Specified by:

visitRemoveCommand in interface Visitor

Overrides:

visitRemoveCommand in class AbstractVisitor

Throws:

Throwable

visitPutKeyValueCommand

public Object visitPutKeyValueCommand(InvocationContext ctx,
                                      PutKeyValueCommand command)
                               throws Throwable

Deprecated.

Specified by:

visitPutKeyValueCommand in interface Visitor

Overrides:

visitPutKeyValueCommand in class AbstractVisitor

Throws:

Throwable

visitPutMapCommand

public Object visitPutMapCommand(InvocationContext ctx,
                                 PutMapCommand command)
                          throws Throwable

Deprecated.

Specified by:

visitPutMapCommand in interface Visitor

Overrides:

visitPutMapCommand in class AbstractVisitor

Throws:

Throwable

visitGetKeyValueCommand

public Object visitGetKeyValueCommand(InvocationContext ctx,
                                      GetKeyValueCommand command)
                               throws Throwable

Deprecated.

Specified by:

visitGetKeyValueCommand in interface Visitor

Overrides:

visitGetKeyValueCommand in class AbstractVisitor

Throws:

Throwable

visitGetCacheEntryCommand

public Object visitGetCacheEntryCommand(InvocationContext ctx,
                                        GetCacheEntryCommand command)
                                 throws Throwable

Deprecated.

Specified by:

visitGetCacheEntryCommand in interface Visitor

Overrides:

visitGetCacheEntryCommand in class AbstractVisitor

Throws:

Throwable

visitLockControlCommand

public Object visitLockControlCommand(TxInvocationContext ctx,
                                      LockControlCommand command)
                               throws Throwable

Deprecated.

Specified by:

visitLockControlCommand in interface Visitor

Overrides:

visitLockControlCommand in class AbstractVisitor

Throws:

Throwable

visitCommitCommand

public Object visitCommitCommand(TxInvocationContext ctx,
                                 CommitCommand command)
                          throws Throwable

Deprecated.

Specified by:

visitCommitCommand in interface Visitor

Overrides:

visitCommitCommand in class AbstractVisitor

Throws:

Throwable

visitPrepareCommand

public Object visitPrepareCommand(TxInvocationContext ctx,
                                  PrepareCommand command)
                           throws Throwable

Deprecated.

Specified by:

visitPrepareCommand in interface Visitor

Overrides:

visitPrepareCommand in class AbstractVisitor

Throws:

Throwable

prepareOnAffectedNodes

protected void prepareOnAffectedNodes(TxInvocationContext<?> ctx,
                                      PrepareCommand command,
                                      Collection<Address> recipients)

Deprecated.

visitRollbackCommand

public Object visitRollbackCommand(TxInvocationContext ctx,
                                   RollbackCommand command)
                            throws Throwable

Deprecated.

Specified by:

visitRollbackCommand in interface Visitor

Overrides:

visitRollbackCommand in class AbstractVisitor

Throws:

Throwable

checkTxCommandResponses

protected void checkTxCommandResponses(Map<Address,Response> responseMap,
                                       TransactionBoundaryCommand command,
                                       LocalTxInvocationContext context,
                                       Collection<Address> recipients)

Deprecated.

writeNeedsRemoteValue

protected boolean writeNeedsRemoteValue(InvocationContext ctx,
                                        WriteCommand command,
                                        Object key)

Deprecated.

Specified by:

writeNeedsRemoteValue in class BaseDistributionInterceptor

Returns:

Whether a remote get is needed to obtain the previous values of the affected entries.

remoteGetBeforeWrite

protected void remoteGetBeforeWrite(InvocationContext ctx,
                                    WriteCommand command,
                                    Object key)
                             throws Throwable

Deprecated.

Specified by:

remoteGetBeforeWrite in class BaseDistributionInterceptor

Throws:

Throwable

remoteGet

protected InternalCacheEntry remoteGet(InvocationContext ctx,
                                       Object key,
                                       boolean isWrite,
                                       FlagAffectedCommand command)
                                throws Throwable

Deprecated.

Throws:

Throwable

createPrepareRpcOptions

protected RpcOptions createPrepareRpcOptions()

Deprecated.