|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use TransactionId | |
---|---|
org.apache.activemq | The core JMS client API implementation classes. |
org.apache.activemq.broker | The core classes for the ActiveMQ Message Broker and its connectors. |
org.apache.activemq.broker.ft | Helper classes for implementing fault tolerance |
org.apache.activemq.broker.region | Region abstraction and implementations in the Broker. |
org.apache.activemq.broker.util | Some utility Broker Plugins |
org.apache.activemq.command | Command objects used via the Command Pattern to communicate among nodes |
org.apache.activemq.ra | JCA managed connections and resource adapters for working with ActiveMQ |
org.apache.activemq.state | |
org.apache.activemq.store | The APIs which need to be implemented for persistent message stores for durable messaging |
org.apache.activemq.store.amq | The default Store implementation for ActiveMQ |
org.apache.activemq.store.journal | Message persistence using a high performance transaction log via the Journal interface. |
org.apache.activemq.store.kahadaptor | kaha implementation of message persistence for the broker |
org.apache.activemq.store.kahadb | |
org.apache.activemq.store.memory | VM based implementation of message persistence |
org.apache.activemq.transaction | |
org.apache.activemq.transport.stomp | An implementation of the Stomp protocol which is a simple wire protocol for writing clients for ActiveMQ in different languages like Ruby, Python, PHP, C etc. |
Uses of TransactionId in org.apache.activemq |
---|
Methods in org.apache.activemq that return TransactionId | |
---|---|
TransactionId |
TransactionContext.getTransactionId()
|
Uses of TransactionId in org.apache.activemq.broker |
---|
Methods in org.apache.activemq.broker that return TransactionId | |
---|---|
TransactionId[] |
BrokerFilter.getPreparedTransactions(ConnectionContext context)
|
TransactionId[] |
EmptyBroker.getPreparedTransactions(ConnectionContext context)
|
TransactionId[] |
TransactionBroker.getPreparedTransactions(ConnectionContext context)
|
TransactionId[] |
MutableBrokerFilter.getPreparedTransactions(ConnectionContext context)
|
TransactionId[] |
Broker.getPreparedTransactions(ConnectionContext context)
Gets a list of all the prepared xa transactions. |
TransactionId[] |
ErrorBroker.getPreparedTransactions(ConnectionContext context)
|
Methods in org.apache.activemq.broker that return types with arguments of type TransactionId | |
---|---|
java.util.concurrent.ConcurrentHashMap<TransactionId,Transaction> |
ConnectionContext.getTransactions()
|
Method parameters in org.apache.activemq.broker with type arguments of type TransactionId | |
---|---|
void |
ConnectionContext.setTransactions(java.util.concurrent.ConcurrentHashMap<TransactionId,Transaction> transactions)
|
Uses of TransactionId in org.apache.activemq.broker.ft |
---|
Methods in org.apache.activemq.broker.ft with parameters of type TransactionId | |
---|---|
void |
MasterBroker.beginTransaction(ConnectionContext context,
TransactionId xid)
begin a transaction |
void |
MasterBroker.commitTransaction(ConnectionContext context,
TransactionId xid,
boolean onePhase)
Commits a transaction. |
void |
MasterBroker.forgetTransaction(ConnectionContext context,
TransactionId xid)
Forgets a transaction. |
int |
MasterBroker.prepareTransaction(ConnectionContext context,
TransactionId xid)
Prepares a transaction. |
void |
MasterBroker.rollbackTransaction(ConnectionContext context,
TransactionId xid)
Rollsback a transaction. |
Uses of TransactionId in org.apache.activemq.broker.region |
---|
Methods in org.apache.activemq.broker.region that return TransactionId | |
---|---|
TransactionId[] |
RegionBroker.getPreparedTransactions(ConnectionContext context)
|
Methods in org.apache.activemq.broker.region with parameters of type TransactionId | |
---|---|
void |
RegionBroker.beginTransaction(ConnectionContext context,
TransactionId xid)
|
void |
RegionBroker.commitTransaction(ConnectionContext context,
TransactionId xid,
boolean onePhase)
|
void |
RegionBroker.forgetTransaction(ConnectionContext context,
TransactionId transactionId)
|
int |
RegionBroker.prepareTransaction(ConnectionContext context,
TransactionId xid)
|
void |
RegionBroker.rollbackTransaction(ConnectionContext context,
TransactionId xid)
|
Uses of TransactionId in org.apache.activemq.broker.util |
---|
Methods in org.apache.activemq.broker.util that return TransactionId | |
---|---|
TransactionId[] |
LoggingBrokerPlugin.getPreparedTransactions(ConnectionContext context)
|
Uses of TransactionId in org.apache.activemq.command |
---|
Subclasses of TransactionId in org.apache.activemq.command | |
---|---|
class |
LocalTransactionId
|
class |
XATransactionId
|
Fields in org.apache.activemq.command declared as TransactionId | |
---|---|
protected TransactionId |
Message.originalTransactionId
|
protected TransactionId |
Message.transactionId
|
protected TransactionId |
MessageAck.transactionId
|
protected TransactionId |
TransactionInfo.transactionId
|
TransactionId |
JournalTransaction.transactionId
|
Methods in org.apache.activemq.command that return TransactionId | |
---|---|
TransactionId |
Message.getOriginalTransactionId()
|
TransactionId |
Message.getTransactionId()
|
TransactionId |
JournalTopicAck.getTransactionId()
|
TransactionId |
MessageAck.getTransactionId()
|
TransactionId |
TransactionInfo.getTransactionId()
|
TransactionId |
JournalTransaction.getTransactionId()
|
Methods in org.apache.activemq.command with parameters of type TransactionId | |
---|---|
void |
Message.setOriginalTransactionId(TransactionId transactionId)
|
void |
Message.setTransactionId(TransactionId transactionId)
|
void |
JournalTopicAck.setTransactionId(TransactionId transaction)
|
void |
MessageAck.setTransactionId(TransactionId transactionId)
|
void |
TransactionInfo.setTransactionId(TransactionId transactionId)
|
void |
JournalTransaction.setTransactionId(TransactionId transactionId)
|
Constructors in org.apache.activemq.command with parameters of type TransactionId | |
---|---|
JournalTransaction(byte type,
TransactionId transactionId,
boolean wasPrepared)
|
|
TransactionInfo(ConnectionId connectionId,
TransactionId transactionId,
byte type)
|
Uses of TransactionId in org.apache.activemq.ra |
---|
Methods in org.apache.activemq.ra that return TransactionId | |
---|---|
TransactionId |
ManagedTransactionContext.getTransactionId()
|
Uses of TransactionId in org.apache.activemq.state |
---|
Methods in org.apache.activemq.state that return TransactionId | |
---|---|
TransactionId |
TransactionState.getId()
|
Methods in org.apache.activemq.state with parameters of type TransactionId | |
---|---|
void |
ConnectionState.addTransactionState(TransactionId id)
|
TransactionState |
ConnectionState.getTransactionState(TransactionId id)
|
TransactionState |
ConnectionState.removeTransactionState(TransactionId id)
|
Constructors in org.apache.activemq.state with parameters of type TransactionId | |
---|---|
TransactionState(TransactionId id)
|
Uses of TransactionId in org.apache.activemq.store |
---|
Methods in org.apache.activemq.store that return types with arguments of type TransactionId | |
---|---|
java.util.Map<TransactionId,AMQTx> |
ReferenceStoreAdapter.retrievePreparedState()
|
Methods in org.apache.activemq.store with parameters of type TransactionId | |
---|---|
void |
TransactionStore.commit(TransactionId txid,
boolean wasPrepared,
java.lang.Runnable preCommit,
java.lang.Runnable postCommit)
|
void |
TransactionStore.prepare(TransactionId txid)
|
void |
TransactionStore.rollback(TransactionId txid)
|
Method parameters in org.apache.activemq.store with type arguments of type TransactionId | |
---|---|
void |
ReferenceStoreAdapter.savePreparedState(java.util.Map<TransactionId,AMQTx> map)
Save prepared transactions |
Uses of TransactionId in org.apache.activemq.store.amq |
---|
Fields in org.apache.activemq.store.amq with type parameters of type TransactionId | |
---|---|
protected java.util.Map<TransactionId,AMQTx> |
AMQTransactionStore.inflightTransactions
|
Methods in org.apache.activemq.store.amq that return types with arguments of type TransactionId | |
---|---|
java.util.Map<TransactionId,AMQTx> |
AMQTransactionStore.getPreparedTransactions()
|
Methods in org.apache.activemq.store.amq with parameters of type TransactionId | |
---|---|
void |
AMQTransactionStore.commit(TransactionId txid,
boolean wasPrepared,
java.lang.Runnable preCommit,
java.lang.Runnable postCommit)
|
AMQTx |
AMQTransactionStore.getTx(TransactionId txid,
Location location)
|
void |
AMQTransactionStore.prepare(TransactionId txid)
|
AMQTx |
AMQTransactionStore.replayCommit(TransactionId txid,
boolean wasPrepared)
|
void |
AMQTransactionStore.replayPrepare(TransactionId txid)
|
void |
AMQTransactionStore.replayRollback(TransactionId txid)
|
void |
AMQTransactionStore.rollback(TransactionId txid)
|
Method parameters in org.apache.activemq.store.amq with type arguments of type TransactionId | |
---|---|
void |
AMQTransactionStore.setPreparedTransactions(java.util.Map<TransactionId,AMQTx> preparedTransactions)
|
Uses of TransactionId in org.apache.activemq.store.journal |
---|
Methods in org.apache.activemq.store.journal with parameters of type TransactionId | |
---|---|
void |
JournalTransactionStore.commit(TransactionId txid,
boolean wasPrepared,
java.lang.Runnable preCommit,
java.lang.Runnable postCommit)
|
void |
JournalTransactionStore.prepare(TransactionId txid)
|
JournalTransactionStore.Tx |
JournalTransactionStore.replayCommit(TransactionId txid,
boolean wasPrepared)
|
void |
JournalTransactionStore.replayPrepare(TransactionId txid)
|
void |
JournalTransactionStore.replayRollback(TransactionId txid)
|
void |
JournalTransactionStore.rollback(TransactionId txid)
|
Uses of TransactionId in org.apache.activemq.store.kahadaptor |
---|
Methods in org.apache.activemq.store.kahadaptor that return types with arguments of type TransactionId | |
---|---|
java.util.Map<TransactionId,AMQTx> |
KahaReferenceStoreAdapter.retrievePreparedState()
|
Methods in org.apache.activemq.store.kahadaptor with parameters of type TransactionId | |
---|---|
void |
KahaTransactionStore.commit(TransactionId txid,
boolean wasPrepared,
java.lang.Runnable before,
java.lang.Runnable after)
|
protected org.apache.activemq.store.kahadaptor.KahaTransaction |
KahaTransactionStore.getOrCreateTx(TransactionId key)
|
protected org.apache.activemq.store.kahadaptor.KahaTransaction |
KahaTransactionStore.getTx(TransactionId key)
|
void |
KahaTransactionStore.prepare(TransactionId txid)
|
protected void |
KahaTransactionStore.removeTx(TransactionId key)
|
void |
KahaTransactionStore.rollback(TransactionId txid)
|
Method parameters in org.apache.activemq.store.kahadaptor with type arguments of type TransactionId | |
---|---|
void |
KahaReferenceStoreAdapter.savePreparedState(java.util.Map<TransactionId,AMQTx> map)
|
Uses of TransactionId in org.apache.activemq.store.kahadb |
---|
Fields in org.apache.activemq.store.kahadb with type parameters of type TransactionId | |
---|---|
protected java.util.LinkedHashMap<TransactionId,java.util.ArrayList<org.apache.activemq.store.kahadb.TempMessageDatabase.Operation>> |
TempMessageDatabase.inflightTransactions
|
protected java.util.LinkedHashMap<TransactionId,java.util.ArrayList<org.apache.activemq.store.kahadb.TempMessageDatabase.Operation>> |
TempMessageDatabase.preparedTransactions
|
protected java.util.LinkedHashMap<TransactionId,java.util.List<org.apache.activemq.store.kahadb.MessageDatabase.Operation>> |
MessageDatabase.preparedTransactions
|
Methods in org.apache.activemq.store.kahadb with parameters of type TransactionId | |
---|---|
void |
MultiKahaDBTransactionStore.commit(TransactionId txid,
boolean wasPrepared,
java.lang.Runnable preCommit,
java.lang.Runnable postCommit)
|
void |
KahaDBTransactionStore.commit(TransactionId txid,
boolean wasPrepared,
java.lang.Runnable preCommit,
java.lang.Runnable postCommit)
|
org.apache.activemq.store.kahadb.data.KahaTransactionInfo |
KahaDBPersistenceAdapter.createTransactionInfo(TransactionId txid)
|
protected void |
KahaDBTransactionStore.forgetRecoveredAcks(TransactionId txid)
|
MultiKahaDBTransactionStore.Tx |
MultiKahaDBTransactionStore.getTx(TransactionId txid)
|
boolean |
MultiKahaDBPersistenceAdapter.isLocalXid(TransactionId xid)
|
void |
MultiKahaDBTransactionStore.persistCompletion(TransactionId txid)
|
void |
MultiKahaDBTransactionStore.persistOutcome(MultiKahaDBTransactionStore.Tx tx,
TransactionId txid)
|
void |
MultiKahaDBTransactionStore.prepare(TransactionId txid)
|
void |
KahaDBTransactionStore.prepare(TransactionId txid)
|
void |
TempMessageDatabase.processAdd(org.apache.activemq.store.kahadb.data.KahaAddMessageCommand command,
TransactionId txid,
ByteSequence data)
|
void |
TempMessageDatabase.processCommit(TransactionId key)
|
void |
TempMessageDatabase.processPrepare(TransactionId key)
|
void |
TempMessageDatabase.processRemove(org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand command,
TransactionId txid)
|
void |
TempMessageDatabase.processRollback(TransactionId key)
|
MultiKahaDBTransactionStore.Tx |
MultiKahaDBTransactionStore.removeTx(TransactionId txid)
|
void |
MultiKahaDBTransactionStore.rollback(TransactionId txid)
|
void |
KahaDBTransactionStore.rollback(TransactionId txid)
|
org.apache.activemq.store.kahadb.data.KahaTransactionInfo |
TransactionIdTransformer.transform(TransactionId txid)
|
Uses of TransactionId in org.apache.activemq.store.memory |
---|
Methods in org.apache.activemq.store.memory with parameters of type TransactionId | |
---|---|
void |
MemoryTransactionStore.commit(TransactionId txid,
boolean wasPrepared,
java.lang.Runnable preCommit,
java.lang.Runnable postCommit)
|
void |
MemoryTransactionStore.prepare(TransactionId txid)
|
void |
MemoryTransactionStore.rollback(TransactionId txid)
|
Uses of TransactionId in org.apache.activemq.transaction |
---|
Methods in org.apache.activemq.transaction that return TransactionId | |
---|---|
TransactionId |
LocalTransaction.getTransactionId()
|
TransactionId |
XATransaction.getTransactionId()
|
abstract TransactionId |
Transaction.getTransactionId()
|
Uses of TransactionId in org.apache.activemq.transport.stomp |
---|
Methods in org.apache.activemq.transport.stomp with parameters of type TransactionId | |
---|---|
MessageAck |
StompSubscription.onStompMessageNack(java.lang.String messageId,
TransactionId transactionId)
|
MessageAck |
StompQueueBrowserSubscription.onStompMessageNack(java.lang.String messageId,
TransactionId transactionId)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |