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.amq |
The default Store implementation for ActiveMQ
|
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.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
|
Constructor and Description |
---|
TempTopic(BrokerService brokerService,
ActiveMQDestination destination,
TopicMessageStore store,
DestinationStatistics parentStats,
TaskRunnerFactory taskFactory) |
Topic(BrokerService brokerService,
ActiveMQDestination destination,
TopicMessageStore store,
DestinationStatistics parentStats,
TaskRunnerFactory taskFactory) |
Modifier and Type | Interface and Description |
---|---|
interface |
TopicReferenceStore
A MessageStore for durable topic subscriptions
|
Modifier and Type | Class and Description |
---|---|
class |
ProxyTopicMessageStore
A simple proxy that delegates to another MessageStore.
|
Modifier and Type | Method and Description |
---|---|
TopicMessageStore |
PersistenceAdapter.createTopicMessageStore(ActiveMQTopic destination)
Factory method to create a new topic message store with the given destination name
|
Constructor and Description |
---|
ProxyTopicMessageStore(TopicMessageStore delegate) |
Modifier and Type | Class and Description |
---|---|
class |
AMQTopicMessageStore
A MessageStore that uses a Journal to store it's messages.
|
Modifier and Type | Method and Description |
---|---|
TopicMessageStore |
AMQPersistenceAdapter.createTopicMessageStore(ActiveMQTopic destinationName) |
Modifier and Type | Class and Description |
---|---|
class |
JDBCTopicMessageStore |
Modifier and Type | Method and Description |
---|---|
TopicMessageStore |
JDBCPersistenceAdapter.createTopicMessageStore(ActiveMQTopic destination) |
Modifier and Type | Class and Description |
---|---|
class |
JournalTopicMessageStore
A MessageStore that uses a Journal to store it's messages.
|
Modifier and Type | Method and Description |
---|---|
TopicMessageStore |
JournalPersistenceAdapter.createTopicMessageStore(ActiveMQTopic destinationName) |
TopicMessageStore |
JournalTopicMessageStore.getLongTermTopicMessageStore() |
Constructor and Description |
---|
JournalTopicMessageStore(JournalPersistenceAdapter adapter,
TopicMessageStore checkpointStore,
ActiveMQTopic destinationName) |
Modifier and Type | Class and Description |
---|---|
class |
KahaTopicMessageStore |
class |
KahaTopicReferenceStore |
Modifier and Type | Field and Description |
---|---|
protected ConcurrentHashMap<ActiveMQTopic,TopicMessageStore> |
KahaPersistenceAdapter.topics |
Modifier and Type | Method and Description |
---|---|
TopicMessageStore |
KahaReferenceStoreAdapter.createTopicMessageStore(ActiveMQTopic destination) |
TopicMessageStore |
KahaPersistenceAdapter.createTopicMessageStore(ActiveMQTopic destination) |
TopicMessageStore |
KahaTransactionStore.proxy(TopicMessageStore messageStore) |
Modifier and Type | Method and Description |
---|---|
TopicMessageStore |
KahaTransactionStore.proxy(TopicMessageStore messageStore) |
Modifier and Type | Method and Description |
---|---|
TopicMessageStore |
KahaDBStore.createTopicMessageStore(ActiveMQTopic destination) |
TopicMessageStore |
MultiKahaDBPersistenceAdapter.createTopicMessageStore(ActiveMQTopic destination) |
TopicMessageStore |
KahaDBPersistenceAdapter.createTopicMessageStore(ActiveMQTopic destination) |
TopicMessageStore |
TempKahaDBStore.createTopicMessageStore(ActiveMQTopic destination) |
TopicMessageStore |
KahaDBTransactionStore.proxy(TopicMessageStore messageStore) |
TopicMessageStore |
MultiKahaDBTransactionStore.proxy(TransactionStore transactionStore,
TopicMessageStore messageStore) |
Modifier and Type | Method and Description |
---|---|
TopicMessageStore |
KahaDBTransactionStore.proxy(TopicMessageStore messageStore) |
TopicMessageStore |
MultiKahaDBTransactionStore.proxy(TransactionStore transactionStore,
TopicMessageStore messageStore) |
Modifier and Type | Class and Description |
---|---|
class |
MemoryTopicMessageStore |
Modifier and Type | Method and Description |
---|---|
TopicMessageStore |
MemoryPersistenceAdapter.createTopicMessageStore(ActiveMQTopic destination) |
TopicMessageStore |
MemoryTransactionStore.proxy(TopicMessageStore messageStore) |
Modifier and Type | Method and Description |
---|---|
TopicMessageStore |
MemoryTransactionStore.proxy(TopicMessageStore messageStore) |
Copyright © 2005–2014 The Apache Software Foundation. All rights reserved.