org.infinispan.transaction
public class TransactionTable extends Object
RemoteTransaction
and TransactionXaAdapter
s (locally
originated transactions).Modifier and Type | Field and Description |
---|---|
static int |
CACHE_STOPPED_TOPOLOGY_ID |
protected boolean |
clustered |
protected ClusteringDependentLogic |
clusteringLogic |
protected CommandsFactory |
commandsFactory |
protected Configuration |
configuration |
protected InvocationContextContainer |
icc |
protected RpcManager |
rpcManager |
protected TransactionCoordinator |
txCoordinator |
protected TransactionFactory |
txFactory |
Constructor and Description |
---|
TransactionTable() |
public static final int CACHE_STOPPED_TOPOLOGY_ID
protected Configuration configuration
protected InvocationContextContainer icc
protected TransactionCoordinator txCoordinator
protected TransactionFactory txFactory
protected RpcManager rpcManager
protected CommandsFactory commandsFactory
protected ClusteringDependentLogic clusteringLogic
protected boolean clustered
public void initialize(RpcManager rpcManager, Configuration configuration, InvocationContextContainer icc, InterceptorChain invoker, CacheNotifier notifier, TransactionFactory gtf, TransactionCoordinator txCoordinator, TransactionSynchronizationRegistry transactionSynchronizationRegistry, CommandsFactory commandsFactory, ClusteringDependentLogic clusteringDependentLogic, Cache cache)
public Set<Object> getLockedKeysForRemoteTransaction(GlobalTransaction gtx)
public void remoteTransactionPrepared(GlobalTransaction gtx)
public void localTransactionPrepared(LocalTransaction localTransaction)
public void enlist(Transaction transaction, LocalTransaction localTransaction)
public void failureCompletingTransaction(Transaction tx)
public boolean containsLocalTx(Transaction tx)
tx
- if null false is returnedpublic int getMinTopologyId()
public void cleanupStaleTransactions(CacheTopology cacheTopology)
public RemoteTransaction getRemoteTransaction(GlobalTransaction txId)
RemoteTransaction
associated with the supplied transaction id. Returns null if no such
association exists.public void remoteTransactionRollback(GlobalTransaction gtx)
public RemoteTransaction getOrCreateRemoteTransaction(GlobalTransaction globalTx, WriteCommand[] modifications)
public LocalTransaction getOrCreateLocalTransaction(Transaction transaction, TxInvocationContext ctx)
TransactionXaAdapter
corresponding to the supplied transaction.
If none exists, will be created first.public boolean removeLocalTransaction(LocalTransaction localTransaction)
TransactionXaAdapter
corresponding to the given tx. Returns true
if such an tx exists.protected final LocalTransaction removeLocalTransactionInternal(Transaction tx)
public void remoteTransactionCommitted(GlobalTransaction gtx)
RemoteTransaction
corresponding to the given tx.public final RemoteTransaction removeRemoteTransaction(GlobalTransaction txId)
public int getRemoteTxCount()
public int getLocalTxCount()
public LocalTransaction getLocalTransaction(GlobalTransaction txId)
txId
- the global transaction identifierpublic LocalTransaction getLocalTransaction(Transaction tx)
public boolean containRemoteTx(GlobalTransaction globalTransaction)
public Collection<RemoteTransaction> getRemoteTransactions()
public Collection<LocalTransaction> getLocalTransactions()
protected final void recalculateMinTopologyIdIfNeeded(CacheTransaction removedTransaction)
public void onTopologyChange(TopologyChangedEvent<?,?> tce)
public void markTransactionCompleted(GlobalTransaction globalTx)
public boolean isTransactionCompleted(GlobalTransaction gtx)
public void cleanupCompletedTransactions()
Copyright © 2015 JBoss, a division of Red Hat. All Rights Reserved.