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.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 |
Destination.getMessageStore() |
MessageStore |
DestinationFilter.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 |
ProxyMessageStore.getDelegate() |
MessageStore |
ProxyTopicMessageStore.getDelegate() |
Constructor and Description |
---|
ProxyMessageStore(MessageStore delegate) |
Modifier and Type | Class and Description |
---|---|
class |
KahaDBStore.KahaDBMessageStore |
class |
TempKahaDBStore.KahaDBMessageStore |
Modifier and Type | Field and Description |
---|---|
protected ConcurrentMap<String,MessageStore> |
MessageDatabase.storeCache
This is a map to cache MessageStores for a specific
KahaDestination key
|
Modifier and Type | Method and Description |
---|---|
MessageStore |
TempKahaDBStore.createQueueMessageStore(ActiveMQQueue destination) |
MessageStore |
KahaDBStore.createQueueMessageStore(ActiveMQQueue destination) |
MessageStore |
KahaDBPersistenceAdapter.createQueueMessageStore(ActiveMQQueue destination) |
MessageStore |
MultiKahaDBPersistenceAdapter.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 |
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–2016 The Apache Software Foundation. All rights reserved.