| Package | Description |
|---|---|
| org.apache.activemq.broker |
The core classes for the ActiveMQ Message Broker and its connectors.
|
| org.apache.activemq.leveldb | |
| org.apache.activemq.store |
The APIs which need to be implemented for persistent message stores for durable messaging
|
| org.apache.activemq.store.jdbc |
Message persistence implemented using JDBC
|
| org.apache.activemq.store.journal |
Message persistence using a high performance transaction log via the Journal interface.
|
| org.apache.activemq.store.kahadb | |
| org.apache.activemq.store.leveldb | |
| org.apache.activemq.store.memory |
VM based implementation of message persistence
|
| org.apache.activemq.transaction |
| Constructor and Description |
|---|
TransactionBroker(Broker next,
TransactionStore transactionStore) |
| Modifier and Type | Class and Description |
|---|---|
class |
org.apache.activemq.leveldb.LevelDBStore |
| Modifier and Type | Method and Description |
|---|---|
TransactionStore |
PersistenceAdapter.createTransactionStore()
Factory method to create a new persistent prepared transaction store for XA recovery
|
| Modifier and Type | Class and Description |
|---|---|
class |
JdbcMemoryTransactionStore
respect 2pc prepare
uses local transactions to maintain prepared state
xid column provides transaction flag for additions and removals
a commit clears that context and completes the work
a rollback clears the flag and removes the additions
Essentially a prepare is an insert &| update transaction
commit|rollback is an update &| remove
|
| Modifier and Type | Method and Description |
|---|---|
TransactionStore |
JDBCPersistenceAdapter.createTransactionStore() |
| Modifier and Type | Class and Description |
|---|---|
class |
JournalTransactionStore |
| Modifier and Type | Method and Description |
|---|---|
TransactionStore |
JournalPersistenceAdapter.createTransactionStore() |
| Modifier and Type | Class and Description |
|---|---|
class |
KahaDBTransactionStore
Provides a TransactionStore implementation that can create transaction aware
MessageStore objects from non transaction aware MessageStore objects.
|
class |
MultiKahaDBTransactionStore |
| Modifier and Type | Method and Description |
|---|---|
TransactionStore |
TempKahaDBStore.createTransactionStore() |
TransactionStore |
MultiKahaDBPersistenceAdapter.createTransactionStore() |
TransactionStore |
KahaDBStore.createTransactionStore() |
TransactionStore |
KahaDBPersistenceAdapter.createTransactionStore() |
| Modifier and Type | Method and Description |
|---|---|
java.util.Set<TransactionStore> |
MultiKahaDBTransactionStore.Tx.getStores() |
| Modifier and Type | Method and Description |
|---|---|
MessageStore |
MultiKahaDBTransactionStore.proxy(TransactionStore transactionStore,
MessageStore messageStore) |
TopicMessageStore |
MultiKahaDBTransactionStore.proxy(TransactionStore transactionStore,
TopicMessageStore messageStore) |
void |
MultiKahaDBTransactionStore.Tx.trackStore(TransactionStore store) |
| Modifier and Type | Class and Description |
|---|---|
class |
LevelDBPersistenceAdapter
An implementation of
PersistenceAdapter designed for use with
LevelDB - Embedded Lightweight Non-Relational Database |
| Modifier and Type | Class and Description |
|---|---|
class |
MemoryTransactionStore
Provides a TransactionStore implementation that can create transaction aware
MessageStore objects from non transaction aware MessageStore objects.
|
| Modifier and Type | Method and Description |
|---|---|
TransactionStore |
MemoryPersistenceAdapter.createTransactionStore() |
| Constructor and Description |
|---|
LocalTransaction(TransactionStore transactionStore,
LocalTransactionId xid,
ConnectionContext context) |
XATransaction(TransactionStore transactionStore,
XATransactionId xid,
TransactionBroker broker,
ConnectionId connectionId) |
Copyright © 2005-2013 Red Hat, Inc.. All Rights Reserved.