Methods
Modifier and Type |
Method and Description |
boolean |
containRemoteTx(GlobalTransaction globalTransaction) |
boolean |
containsLocalTx(Transaction tx)
Returns true if the given transaction is already registered with the transaction table.
|
RemoteTransaction |
createRemoteTransaction(GlobalTransaction globalTx,
WriteCommand[] modifications)
|
void |
enlist(Transaction transaction,
LocalTransaction localTransaction) |
void |
failureCompletingTransaction(Transaction tx) |
LocalTransaction |
getLocalTransaction(Transaction tx) |
Collection<LocalTransaction> |
getLocalTransactions() |
protected LocalTransaction |
getLocalTx(Transaction tx) |
int |
getLocalTxCount() |
Set<Object> |
getLockedKeysForRemoteTransaction(GlobalTransaction gtx) |
int |
getMinViewId() |
LocalTransaction |
getOrCreateLocalTransaction(Transaction transaction,
TxInvocationContext ctx)
|
RemoteTransaction |
getRemoteTransaction(GlobalTransaction txId)
|
Collection<RemoteTransaction> |
getRemoteTransactions() |
int |
getRemoteTxCount() |
void |
initialize(RpcManager rpcManager,
Configuration configuration,
InvocationContextContainer icc,
InterceptorChain invoker,
CacheNotifier notifier,
TransactionFactory gtf,
EmbeddedCacheManager cm,
TransactionCoordinator txCoordinator,
TransactionSynchronizationRegistry transactionSynchronizationRegistry,
CommandsFactory commandsFactory,
ClusteringDependentLogic clusteringDependentLogic) |
void |
localTransactionPrepared(LocalTransaction localTransaction) |
protected void |
recalculateMinViewIdIfNeeded(CacheTransaction removedTransaction) |
void |
recalculateMinViewIdOnTopologyChange(ViewChangedEvent vce) |
void |
remoteTransactionCommitted(GlobalTransaction gtx)
|
void |
remoteTransactionPrepared(GlobalTransaction gtx) |
void |
remoteTransactionRollback(GlobalTransaction gtx) |
boolean |
removeLocalTransaction(LocalTransaction localTransaction)
|
LocalTransaction |
removeLocalTransaction(Transaction tx) |
protected LocalTransaction |
removeLocalTransactionInternal(Transaction tx) |
RemoteTransaction |
removeRemoteTransaction(GlobalTransaction txId) |
protected void |
updateStateOnNodesLeaving(Collection<Address> leavers) |