| Package | Description |
|---|---|
| org.apache.activemq.broker.region |
Region abstraction and implementations in the Broker.
|
| 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.memory |
VM based implementation of message persistence
|
| Modifier and Type | Field and Description |
|---|---|
protected MessageStore |
BaseDestination.store |
| Modifier and Type | Method and Description |
|---|---|
MessageStore |
DestinationFilter.getMessageStore() |
MessageStore |
Destination.getMessageStore() |
MessageStore |
BaseDestination.getMessageStore() |
| Constructor and Description |
|---|
BaseDestination(BrokerService brokerService,
MessageStore store,
ActiveMQDestination destination,
DestinationStatistics parentStats) |
Queue(BrokerService brokerService,
ActiveMQDestination destination,
MessageStore store,
DestinationStatistics parentStats,
TaskRunnerFactory taskFactory) |
TempQueue(BrokerService brokerService,
ActiveMQDestination destination,
MessageStore store,
DestinationStatistics parentStats,
TaskRunnerFactory taskFactory) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
ReferenceStore
Represents a message store which is used by the persistent implementations
|
interface |
TopicMessageStore
A MessageStore for durable topic subscriptions
|
interface |
TopicReferenceStore
A MessageStore for durable topic subscriptions
|
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractMessageStore |
class |
ProxyMessageStore
A simple proxy that delegates to another MessageStore.
|
class |
ProxyTopicMessageStore
A simple proxy that delegates to another MessageStore.
|
| Modifier and Type | Method and Description |
|---|---|
MessageStore |
PersistenceAdapter.createQueueMessageStore(ActiveMQQueue destination)
Factory method to create a new queue message store with the given
destination name
|
MessageStore |
ProxyTopicMessageStore.getDelegate() |
MessageStore |
ProxyMessageStore.getDelegate() |
| Constructor and Description |
|---|
ProxyMessageStore(MessageStore delegate) |
| Modifier and Type | Class and Description |
|---|---|
class |
JDBCMessageStore |
class |
JDBCTopicMessageStore |
| Modifier and Type | Method and Description |
|---|---|
MessageStore |
JDBCPersistenceAdapter.createQueueMessageStore(ActiveMQQueue destination) |
| Modifier and Type | Class and Description |
|---|---|
class |
JournalMessageStore
A MessageStore that uses a Journal to store it's messages.
|
class |
JournalTopicMessageStore
A MessageStore that uses a Journal to store it's messages.
|
| Modifier and Type | Field and Description |
|---|---|
protected MessageStore |
JournalMessageStore.longTermStore |
| Modifier and Type | Method and Description |
|---|---|
MessageStore |
JournalPersistenceAdapter.createQueueMessageStore(ActiveMQQueue destination) |
MessageStore |
JournalMessageStore.getLongTermMessageStore() |
| Constructor and Description |
|---|
JournalMessageStore(JournalPersistenceAdapter adapter,
MessageStore checkpointStore,
ActiveMQDestination destination) |
| Modifier and Type | Class and Description |
|---|---|
class |
KahaDBStore.KahaDBMessageStore |
class |
TempKahaDBStore.KahaDBMessageStore |
| Modifier and Type | Method and Description |
|---|---|
MessageStore |
TempKahaDBStore.createQueueMessageStore(ActiveMQQueue destination) |
MessageStore |
MultiKahaDBPersistenceAdapter.createQueueMessageStore(ActiveMQQueue destination) |
MessageStore |
KahaDBStore.createQueueMessageStore(ActiveMQQueue destination) |
MessageStore |
KahaDBPersistenceAdapter.createQueueMessageStore(ActiveMQQueue destination) |
MessageStore |
KahaDBTransactionStore.proxy(MessageStore messageStore) |
MessageStore |
MultiKahaDBTransactionStore.proxy(TransactionStore transactionStore,
MessageStore messageStore) |
| Modifier and Type | Method and Description |
|---|---|
MessageStore |
KahaDBTransactionStore.proxy(MessageStore messageStore) |
MessageStore |
MultiKahaDBTransactionStore.proxy(TransactionStore transactionStore,
MessageStore messageStore) |
| Modifier and Type | Class and Description |
|---|---|
class |
MemoryMessageStore
An implementation of
MessageStore which
uses a |
class |
MemoryTopicMessageStore |
| Modifier and Type | Method and Description |
|---|---|
MessageStore |
MemoryPersistenceAdapter.createQueueMessageStore(ActiveMQQueue destination) |
MessageStore |
MemoryTransactionStore.AddMessageCommand.getMessageStore() |
MessageStore |
MemoryTransactionStore.RemoveMessageCommand.getMessageStore() |
MessageStore |
MemoryTransactionStore.proxy(MessageStore messageStore) |
| Modifier and Type | Method and Description |
|---|---|
MessageStore |
MemoryTransactionStore.proxy(MessageStore messageStore) |
void |
MemoryTransactionStore.AddMessageCommand.setMessageStore(MessageStore messageStore) |
Copyright © 2005–2015 FuseSource, Corp.. All rights reserved.