Package | Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
TransactionId |
TransactionContext.getTransactionId() |
Modifier and Type | Method and Description |
---|---|
TransactionId[] |
Broker.getPreparedTransactions(ConnectionContext context)
Gets a list of all the prepared xa transactions.
|
TransactionId[] |
TransactionBroker.getPreparedTransactions(ConnectionContext context) |
TransactionId[] |
ErrorBroker.getPreparedTransactions(ConnectionContext context) |
TransactionId[] |
MutableBrokerFilter.getPreparedTransactions(ConnectionContext context) |
TransactionId[] |
EmptyBroker.getPreparedTransactions(ConnectionContext context) |
TransactionId[] |
BrokerFilter.getPreparedTransactions(ConnectionContext context) |
Modifier and Type | Method and Description |
---|---|
ConcurrentHashMap<TransactionId,Transaction> |
ConnectionContext.getTransactions() |
Modifier and Type | Method and Description |
---|---|
void |
ConnectionContext.setTransactions(ConcurrentHashMap<TransactionId,Transaction> transactions) |
Modifier and Type | Method and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
TransactionId[] |
RegionBroker.getPreparedTransactions(ConnectionContext context) |
Modifier and Type | Method and Description |
---|---|
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) |
Modifier and Type | Method and Description |
---|---|
TransactionId[] |
LoggingBrokerPlugin.getPreparedTransactions(ConnectionContext context) |
Modifier and Type | Method and Description |
---|---|
void |
UDPTraceBrokerPlugin.beginTransaction(ConnectionContext context,
TransactionId xid) |
void |
LoggingBrokerPlugin.beginTransaction(ConnectionContext context,
TransactionId xid) |
void |
UDPTraceBrokerPlugin.commitTransaction(ConnectionContext context,
TransactionId xid,
boolean onePhase) |
void |
LoggingBrokerPlugin.commitTransaction(ConnectionContext context,
TransactionId xid,
boolean onePhase) |
void |
UDPTraceBrokerPlugin.forgetTransaction(ConnectionContext context,
TransactionId xid) |
void |
LoggingBrokerPlugin.forgetTransaction(ConnectionContext context,
TransactionId transactionId) |
int |
UDPTraceBrokerPlugin.prepareTransaction(ConnectionContext context,
TransactionId xid) |
int |
LoggingBrokerPlugin.prepareTransaction(ConnectionContext context,
TransactionId xid) |
void |
UDPTraceBrokerPlugin.rollbackTransaction(ConnectionContext context,
TransactionId xid) |
void |
LoggingBrokerPlugin.rollbackTransaction(ConnectionContext context,
TransactionId xid) |
Modifier and Type | Class and Description |
---|---|
class |
LocalTransactionId |
class |
XATransactionId |
Modifier and Type | Field and Description |
---|---|
protected TransactionId |
Message.originalTransactionId |
protected TransactionId |
TransactionInfo.transactionId |
TransactionId |
JournalTransaction.transactionId |
protected TransactionId |
Message.transactionId |
protected TransactionId |
MessageAck.transactionId |
Modifier and Type | Method and Description |
---|---|
TransactionId |
Message.getOriginalTransactionId() |
TransactionId |
TransactionInfo.getTransactionId() |
TransactionId |
JournalTopicAck.getTransactionId() |
TransactionId |
JournalTransaction.getTransactionId() |
TransactionId |
Message.getTransactionId() |
TransactionId |
MessageAck.getTransactionId() |
Modifier and Type | Method and Description |
---|---|
void |
Message.setOriginalTransactionId(TransactionId transactionId) |
void |
TransactionInfo.setTransactionId(TransactionId transactionId) |
void |
JournalTopicAck.setTransactionId(TransactionId transaction) |
void |
JournalTransaction.setTransactionId(TransactionId transactionId) |
void |
Message.setTransactionId(TransactionId transactionId) |
void |
MessageAck.setTransactionId(TransactionId transactionId) |
Constructor and Description |
---|
JournalTransaction(byte type,
TransactionId transactionId,
boolean wasPrepared) |
TransactionInfo(ConnectionId connectionId,
TransactionId transactionId,
byte type) |
Modifier and Type | Method and Description |
---|---|
TransactionId |
ManagedTransactionContext.getTransactionId() |
Modifier and Type | Method and Description |
---|---|
TransactionId |
TransactionState.getId() |
Modifier and Type | Method and Description |
---|---|
void |
ConnectionState.addTransactionState(TransactionId id) |
TransactionState |
ConnectionState.getTransactionState(TransactionId id) |
TransactionState |
ConnectionState.removeTransactionState(TransactionId id) |
Constructor and Description |
---|
TransactionState(TransactionId id) |
Modifier and Type | Method and Description |
---|---|
Map<TransactionId,AMQTx> |
ReferenceStoreAdapter.retrievePreparedState() |
Modifier and Type | Method and Description |
---|---|
void |
TransactionStore.commit(TransactionId txid,
boolean wasPrepared,
Runnable preCommit,
Runnable postCommit) |
void |
TransactionStore.prepare(TransactionId txid) |
void |
TransactionStore.rollback(TransactionId txid) |
Modifier and Type | Method and Description |
---|---|
void |
ReferenceStoreAdapter.savePreparedState(Map<TransactionId,AMQTx> map)
Save prepared transactions
|
Modifier and Type | Field and Description |
---|---|
protected Map<TransactionId,AMQTx> |
AMQTransactionStore.inflightTransactions |
Modifier and Type | Method and Description |
---|---|
Map<TransactionId,AMQTx> |
AMQTransactionStore.getPreparedTransactions() |
Modifier and Type | Method and Description |
---|---|
void |
AMQTransactionStore.commit(TransactionId txid,
boolean wasPrepared,
Runnable preCommit,
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) |
Modifier and Type | Method and Description |
---|---|
void |
AMQTransactionStore.setPreparedTransactions(Map<TransactionId,AMQTx> preparedTransactions) |
Modifier and Type | Method and Description |
---|---|
void |
JournalTransactionStore.commit(TransactionId txid,
boolean wasPrepared,
Runnable preCommit,
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) |
Modifier and Type | Method and Description |
---|---|
Map<TransactionId,AMQTx> |
KahaReferenceStoreAdapter.retrievePreparedState() |
Modifier and Type | Method and Description |
---|---|
void |
KahaTransactionStore.commit(TransactionId txid,
boolean wasPrepared,
Runnable before,
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) |
Modifier and Type | Method and Description |
---|---|
void |
KahaReferenceStoreAdapter.savePreparedState(Map<TransactionId,AMQTx> map) |
Modifier and Type | Field and Description |
---|---|
protected LinkedHashMap<TransactionId,ArrayList<org.apache.activemq.store.kahadb.TempMessageDatabase.Operation>> |
TempMessageDatabase.inflightTransactions |
protected LinkedHashMap<TransactionId,List<org.apache.activemq.store.kahadb.MessageDatabase.Operation>> |
MessageDatabase.preparedTransactions |
protected LinkedHashMap<TransactionId,ArrayList<org.apache.activemq.store.kahadb.TempMessageDatabase.Operation>> |
TempMessageDatabase.preparedTransactions |
Modifier and Type | Method and Description |
---|---|
void |
KahaDBTransactionStore.commit(TransactionId txid,
boolean wasPrepared,
Runnable preCommit,
Runnable postCommit) |
void |
MultiKahaDBTransactionStore.commit(TransactionId txid,
boolean wasPrepared,
Runnable preCommit,
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 |
KahaDBTransactionStore.prepare(TransactionId txid) |
void |
MultiKahaDBTransactionStore.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 |
KahaDBTransactionStore.rollback(TransactionId txid) |
void |
MultiKahaDBTransactionStore.rollback(TransactionId txid) |
org.apache.activemq.store.kahadb.data.KahaTransactionInfo |
TransactionIdTransformer.transform(TransactionId txid) |
Modifier and Type | Method and Description |
---|---|
void |
MemoryTransactionStore.commit(TransactionId txid,
boolean wasPrepared,
Runnable preCommit,
Runnable postCommit) |
void |
MemoryTransactionStore.prepare(TransactionId txid) |
void |
MemoryTransactionStore.rollback(TransactionId txid) |
Modifier and Type | Method and Description |
---|---|
TransactionId |
LocalTransaction.getTransactionId() |
TransactionId |
XATransaction.getTransactionId() |
abstract TransactionId |
Transaction.getTransactionId() |
Modifier and Type | Method and Description |
---|---|
MessageAck |
StompSubscription.onStompMessageNack(String messageId,
TransactionId transactionId) |
MessageAck |
StompQueueBrowserSubscription.onStompMessageNack(String messageId,
TransactionId transactionId) |
Copyright © 2005–2015. All rights reserved.