Package | Description |
---|---|
javax.transaction |
Provides the API that defines the contract between the transaction
manager and the various parties involved in a distributed transaction
namely : resource manager, application, and application server.
|
org.hibernate.engine.transaction.jta.platform.internal | |
org.hibernate.engine.transaction.jta.platform.spi | |
org.infinispan.batch |
Support for batching calls using the
BatchingCache.startBatch() and BatchingCache.endBatch(boolean)
API. |
org.infinispan.client.hotrod.impl.transaction | |
org.infinispan.client.hotrod.transaction.manager | |
org.infinispan.commons.tx | |
org.infinispan.configuration.cache |
Cache configuration |
org.infinispan.context |
Contexts contain information of a specific invocation on the cache, such as its origins, scope
(transactional or non-transactional), as well as invocation-specific flags.
|
org.infinispan.context.impl |
This package contains different context implementations, selected dynamically based on the type of invocation.
|
org.infinispan.notifications.cachelistener |
Cache -specific notifications and eventing. |
org.infinispan.notifications.cachemanagerlistener |
CacheManager -specific notifications and eventing. |
org.infinispan.notifications.impl | |
org.infinispan.persistence.spi |
The Persistence SPI.
|
org.infinispan.persistence.support | |
org.infinispan.transaction |
JTA transaction support.
|
org.infinispan.transaction.impl | |
org.infinispan.transaction.synchronization | |
org.infinispan.transaction.tm |
Infinispan's bare-bones internal transaction manager, used for batching calls as well as as a dummy, unit-test-only
transaction manager.
|
org.infinispan.transaction.xa |
XA transaction support.
|
org.infinispan.transaction.xa.recovery | |
org.infinispan.xsite | |
org.jboss.ejb._private | |
org.jboss.ejb.client | |
org.jboss.ejb.server |
Modifier and Type | Method and Description |
---|---|
Transaction |
TransactionManager.getTransaction()
Get the transaction object that represents the transaction
context of the calling thread.
|
Transaction |
TransactionManager.suspend()
Suspend the transaction currently associated with the calling
thread and return a Transaction object that represents the
transaction context being suspended.
|
Modifier and Type | Method and Description |
---|---|
void |
TransactionManager.resume(Transaction tobj)
Resume the transaction context association of the calling thread
with the transaction represented by the supplied Transaction object.
|
Modifier and Type | Class and Description |
---|---|
class |
WebSphereExtendedJtaPlatform.TransactionManagerAdapter.TransactionAdapter |
Modifier and Type | Method and Description |
---|---|
Transaction |
WebSphereExtendedJtaPlatform.TransactionManagerAdapter.getTransaction() |
Transaction |
WebSphereExtendedJtaPlatform.TransactionManagerAdapter.suspend() |
Modifier and Type | Method and Description |
---|---|
Object |
AbstractJtaPlatform.getTransactionIdentifier(Transaction transaction) |
Object |
NoJtaPlatform.getTransactionIdentifier(Transaction transaction) |
Object |
WebSphereExtendedJtaPlatform.getTransactionIdentifier(Transaction transaction) |
Object |
WebSphereLibertyJtaPlatform.getTransactionIdentifier(Transaction transaction) |
void |
WebSphereExtendedJtaPlatform.TransactionManagerAdapter.resume(Transaction txn) |
Modifier and Type | Method and Description |
---|---|
Object |
JtaPlatform.getTransactionIdentifier(Transaction transaction)
Determine an identifier for the given transaction appropriate for use in caching/lookup usages.
|
Modifier and Type | Method and Description |
---|---|
Transaction |
BatchContainer.getBatchTransaction() |
Modifier and Type | Method and Description |
---|---|
<K,V> TransactionContext<K,V> |
SyncModeTransactionTable.enlist(TransactionalRemoteCacheImpl<K,V> txRemoteCache,
Transaction tx) |
<K,V> TransactionContext<K,V> |
TransactionTable.enlist(TransactionalRemoteCacheImpl<K,V> txRemoteCache,
Transaction tx) |
<K,V> TransactionContext<K,V> |
XaModeTransactionTable.enlist(TransactionalRemoteCacheImpl<K,V> txRemoteCache,
Transaction tx) |
Modifier and Type | Method and Description |
---|---|
protected Transaction |
RemoteTransactionManager.createTransaction() |
Modifier and Type | Class and Description |
---|---|
class |
TransactionImpl
A basic
Transaction implementation. |
Modifier and Type | Method and Description |
---|---|
protected abstract Transaction |
TransactionManagerImpl.createTransaction() |
Transaction |
TransactionManagerImpl.getTransaction() |
Transaction |
TransactionManagerImpl.suspend() |
Modifier and Type | Method and Description |
---|---|
void |
TransactionManagerImpl.resume(Transaction tx) |
Modifier and Type | Method and Description |
---|---|
void |
CustomFailurePolicy.handleCommitFailure(String site,
Transaction transaction) |
void |
CustomFailurePolicy.handlePrepareFailure(String site,
Transaction transaction) |
void |
CustomFailurePolicy.handleRollbackFailure(String site,
Transaction transaction) |
Modifier and Type | Method and Description |
---|---|
InvocationContext |
InvocationContextFactory.createInvocationContext(Transaction tx,
boolean implicitTransaction)
Creates an invocation context
|
Modifier and Type | Method and Description |
---|---|
Transaction |
RemoteTxInvocationContext.getTransaction() |
Transaction |
TxInvocationContext.getTransaction()
Returns the tx associated with the current thread.
|
Transaction |
LocalTxInvocationContext.getTransaction() |
Modifier and Type | Method and Description |
---|---|
InvocationContext |
NonTransactionalInvocationContextFactory.createInvocationContext(Transaction tx,
boolean implicitTransaction) |
InvocationContext |
TransactionalInvocationContextFactory.createInvocationContext(Transaction tx,
boolean implicitTransaction) |
Modifier and Type | Method and Description |
---|---|
protected Transaction |
CacheNotifierImpl.suspendIfNeeded() |
Modifier and Type | Method and Description |
---|---|
protected void |
CacheNotifierImpl.resumeIfNeeded(Transaction transaction) |
Modifier and Type | Method and Description |
---|---|
protected Transaction |
CacheManagerNotifierImpl.suspendIfNeeded() |
Modifier and Type | Method and Description |
---|---|
protected void |
CacheManagerNotifierImpl.resumeIfNeeded(Transaction transaction) |
Modifier and Type | Method and Description |
---|---|
protected abstract Transaction |
AbstractListenerImpl.suspendIfNeeded() |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
AbstractListenerImpl.resumeIfNeeded(Transaction transaction) |
Modifier and Type | Method and Description |
---|---|
default CompletionStage<Void> |
NonBlockingStore.commit(Transaction transaction)
Commit changes in the provided transaction to the underlying store.
|
void |
TransactionalCacheWriter.commit(Transaction transaction)
Deprecated.
Commit the provided transaction's changes to the underlying store.
|
void |
TransactionalCacheWriter.prepareWithModifications(Transaction transaction,
BatchModification batchModification)
Deprecated.
Write modifications to the store in the prepare phase, as this is the only way we know the FINAL values of the entries.
|
default CompletionStage<Void> |
NonBlockingStore.prepareWithModifications(Transaction transaction,
int publisherCount,
org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<Object>> removePublisher,
org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher)
Write remove and put modifications to the store in the prepare phase, which should not yet persisted until the
same transaction is committed via
NonBlockingStore.commit(Transaction) or they are discarded if the transaction is rolled back via
NonBlockingStore.rollback(Transaction) . |
default CompletionStage<Void> |
NonBlockingStore.rollback(Transaction transaction)
Roll back the changes from the provided transaction to the underlying store.
|
void |
TransactionalCacheWriter.rollback(Transaction transaction)
Deprecated.
Rollback the provided transaction's changes to the underlying store.
|
Modifier and Type | Method and Description |
---|---|
CompletionStage<Void> |
DelegatingNonBlockingStore.commit(Transaction transaction) |
CompletionStage<Void> |
NonBlockingStoreAdapter.commit(Transaction transaction) |
CompletionStage<Void> |
DelegatingNonBlockingStore.prepareWithModifications(Transaction transaction,
int publisherCount,
org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<Object>> removePublisher,
org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher) |
CompletionStage<Void> |
NonBlockingStoreAdapter.prepareWithModifications(Transaction transaction,
int publisherCount,
org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<Object>> removePublisher,
org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher) |
CompletionStage<Void> |
DelegatingNonBlockingStore.rollback(Transaction transaction) |
CompletionStage<Void> |
NonBlockingStoreAdapter.rollback(Transaction transaction) |
Modifier and Type | Method and Description |
---|---|
GlobalTransaction |
TransactionTable.getGlobalTransaction(Transaction transaction) |
Modifier and Type | Method and Description |
---|---|
Transaction |
LocalTransaction.getTransaction() |
Modifier and Type | Method and Description |
---|---|
void |
TransactionTable.enlist(Transaction transaction,
LocalTransaction localTransaction) |
void |
TransactionTable.enlistClientTransaction(Transaction transaction,
LocalTransaction localTransaction) |
void |
TransactionTable.failureCompletingTransaction(Transaction tx) |
GlobalTransaction |
TransactionTable.getGlobalTransaction(Transaction transaction) |
LocalTransaction |
TransactionTable.getLocalTransaction(Transaction tx) |
LocalTransaction |
TransactionTable.getOrCreateLocalTransaction(Transaction transaction,
boolean implicitTransaction)
Returns the
TransactionXaAdapter corresponding to the supplied transaction. |
LocalTransaction |
TransactionTable.getOrCreateLocalTransaction(Transaction transaction,
boolean implicitTransaction,
Supplier<GlobalTransaction> gtxFactory)
Similar to
TransactionTable.getOrCreateLocalTransaction(Transaction, boolean) but with a custom global transaction factory. |
Constructor and Description |
---|
LocalTransaction(Transaction transaction,
GlobalTransaction tx,
boolean implicitTransaction,
int topologyId,
long txCreationTime) |
Constructor and Description |
---|
SyncLocalTransaction(Transaction transaction,
GlobalTransaction tx,
boolean implicitTransaction,
int topologyId,
long txCreationTime) |
Modifier and Type | Class and Description |
---|---|
class |
EmbeddedTransaction
A
Transaction implementation used by EmbeddedBaseTransactionManager . |
Modifier and Type | Method and Description |
---|---|
void |
XaTransactionTable.enlist(Transaction transaction,
LocalTransaction ltx) |
void |
XaTransactionTable.enlistClientTransaction(Transaction transaction,
LocalTransaction localTransaction) |
LocalTransaction |
TransactionFactory.newLocalTransaction(Transaction tx,
GlobalTransaction gtx,
boolean implicitTransaction,
int topologyId) |
abstract LocalTransaction |
TransactionFactory.TxFactoryEnum.newLocalTransaction(Transaction tx,
GlobalTransaction gtx,
boolean implicitTransaction,
int topologyId,
long txCreationTime) |
Constructor and Description |
---|
LocalXaTransaction(Transaction transaction,
GlobalTransaction tx,
boolean implicitTransaction,
int topologyId,
long txCreationTime) |
Modifier and Type | Method and Description |
---|---|
void |
RecoveryAwareTransactionTable.failureCompletingTransaction(Transaction tx) |
Constructor and Description |
---|
RecoveryAwareLocalTransaction(Transaction transaction,
GlobalTransaction tx,
boolean implicitTransaction,
int topologyId,
long txCreationTime) |
Modifier and Type | Method and Description |
---|---|
InvocationStage |
BackupSender.backupCommit(CommitCommand command,
Transaction transaction) |
InvocationStage |
BackupSenderImpl.backupCommit(CommitCommand command,
Transaction transaction) |
InvocationStage |
NoOpBackupSender.backupCommit(CommitCommand command,
Transaction transaction) |
InvocationStage |
BackupSender.backupPrepare(PrepareCommand command,
AbstractCacheTransaction cacheTransaction,
Transaction transaction)
Prepares a transaction on the remote site.
|
InvocationStage |
BackupSenderImpl.backupPrepare(PrepareCommand command,
AbstractCacheTransaction cacheTransaction,
Transaction transaction) |
InvocationStage |
NoOpBackupSender.backupPrepare(PrepareCommand command,
AbstractCacheTransaction cacheTransaction,
Transaction transaction) |
InvocationStage |
BackupSender.backupRollback(RollbackCommand command,
Transaction transaction) |
InvocationStage |
BackupSenderImpl.backupRollback(RollbackCommand command,
Transaction transaction) |
InvocationStage |
NoOpBackupSender.backupRollback(RollbackCommand command,
Transaction transaction) |
void |
AbstractCustomFailurePolicy.handleCommitFailure(String site,
Transaction transaction) |
void |
AbstractCustomFailurePolicy.handlePrepareFailure(String site,
Transaction transaction) |
void |
AbstractCustomFailurePolicy.handleRollbackFailure(String site,
Transaction transaction) |
Modifier and Type | Method and Description |
---|---|
SystemException |
Logs.outflowTransactionTimeoutElapsed(Transaction transaction) |
SystemException |
Logs_$logger.outflowTransactionTimeoutElapsed(Transaction transaction) |
Modifier and Type | Field and Description |
---|---|
static AttachmentKey<Transaction> |
AttachmentKeys.TRANSACTION_KEY
The attachment key for transaction propagation.
|
Modifier and Type | Method and Description |
---|---|
Transaction |
InvocationRequest.Resolved.getTransaction()
Get the inflowed transaction of the request.
|
Transaction |
SessionOpenRequest.getTransaction()
Get the inflowed transaction of the request.
|
Copyright © 2021 JBoss by Red Hat. All rights reserved.