Package | Description |
---|---|
org.apache.activemq.advisory |
Support for JMS Advisory messages as well as some helper listeners to listen to the clients, producers and consumers available.
|
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
|
Modifier and Type | Field and Description |
---|---|
static ActiveMQTopic |
AdvisorySupport.ALL_DESTINATIONS_COMPOSITE_ADVISORY_TOPIC |
static ActiveMQTopic |
AdvisorySupport.CONNECTION_ADVISORY_TOPIC |
static ActiveMQTopic |
AdvisorySupport.QUEUE_ADVISORY_TOPIC |
static ActiveMQTopic |
AdvisorySupport.TEMP_DESTINATION_COMPOSITE_ADVISORY_TOPIC |
static ActiveMQTopic |
AdvisorySupport.TEMP_QUEUE_ADVISORY_TOPIC |
static ActiveMQTopic |
AdvisorySupport.TEMP_TOPIC_ADVISORY_TOPIC |
static ActiveMQTopic |
AdvisorySupport.TOPIC_ADVISORY_TOPIC |
Modifier and Type | Method and Description |
---|---|
Set<ActiveMQTopic> |
DestinationSource.getTopics()
Returns the current topics on the broker
|
Modifier and Type | Method and Description |
---|---|
protected void |
AdvisoryBroker.fireAdvisory(ConnectionContext context,
ActiveMQTopic topic,
Command command) |
protected void |
AdvisoryBroker.fireAdvisory(ConnectionContext context,
ActiveMQTopic topic,
Command command,
ConsumerId targetConsumerId) |
protected void |
AdvisoryBroker.fireAdvisory(ConnectionContext context,
ActiveMQTopic topic,
Command command,
ConsumerId targetConsumerId,
ActiveMQMessage advisoryMessage) |
protected void |
AdvisoryBroker.fireConsumerAdvisory(ConnectionContext context,
ActiveMQDestination consumerDestination,
ActiveMQTopic topic,
Command command) |
protected void |
AdvisoryBroker.fireConsumerAdvisory(ConnectionContext context,
ActiveMQDestination consumerDestination,
ActiveMQTopic topic,
Command command,
ConsumerId targetConsumerId) |
protected void |
AdvisoryBroker.fireProducerAdvisory(ConnectionContext context,
ActiveMQDestination producerDestination,
ActiveMQTopic topic,
Command command) |
protected void |
AdvisoryBroker.fireProducerAdvisory(ConnectionContext context,
ActiveMQDestination producerDestination,
ActiveMQTopic topic,
Command command,
ConsumerId targetConsumerId) |
Modifier and Type | Method and Description |
---|---|
abstract SubscriptionInfo[] |
DestinationFactory.getAllDurableSubscriptions(ActiveMQTopic topic)
Lists all the durable subscirptions for a given destination.
|
SubscriptionInfo[] |
DestinationFactoryImpl.getAllDurableSubscriptions(ActiveMQTopic topic) |
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
|
TopicReferenceStore |
ReferenceStoreAdapter.createTopicReferenceStore(ActiveMQTopic destination)
Factory method to create a new topic message store with the given
destination name
|
void |
PersistenceAdapter.removeTopicMessageStore(ActiveMQTopic destination)
Cleanup method to remove any state associated with the given destination
This method does not stop the message store (it might not be cached).
|
Modifier and Type | Method and Description |
---|---|
TopicMessageStore |
AMQPersistenceAdapter.createTopicMessageStore(ActiveMQTopic destinationName) |
void |
AMQPersistenceAdapter.removeTopicMessageStore(ActiveMQTopic destination)
Cleanup method to remove any state associated with the given destination
|
Constructor and Description |
---|
AMQTopicMessageStore(AMQPersistenceAdapter adapter,
TopicReferenceStore topicReferenceStore,
ActiveMQTopic destinationName) |
Modifier and Type | Method and Description |
---|---|
TopicMessageStore |
JDBCPersistenceAdapter.createTopicMessageStore(ActiveMQTopic destination) |
void |
JDBCPersistenceAdapter.removeTopicMessageStore(ActiveMQTopic destination)
Cleanup method to remove any state associated with the given destination
No state retained....
|
Constructor and Description |
---|
JDBCTopicMessageStore(JDBCPersistenceAdapter persistenceAdapter,
JDBCAdapter adapter,
WireFormat wireFormat,
ActiveMQTopic topic,
ActiveMQMessageAudit audit) |
Modifier and Type | Method and Description |
---|---|
TopicMessageStore |
JournalPersistenceAdapter.createTopicMessageStore(ActiveMQTopic destinationName) |
void |
JournalPersistenceAdapter.removeTopicMessageStore(ActiveMQTopic destination)
Cleanup method to remove any state associated with the given destination
|
Constructor and Description |
---|
JournalTopicMessageStore(JournalPersistenceAdapter adapter,
TopicMessageStore checkpointStore,
ActiveMQTopic destinationName) |
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) |
TopicReferenceStore |
KahaReferenceStoreAdapter.createTopicReferenceStore(ActiveMQTopic destination) |
void |
KahaPersistenceAdapter.removeTopicMessageStore(ActiveMQTopic destination)
Cleanup method to remove any state associated with the given destination
|
Modifier and Type | Method and Description |
---|---|
TopicMessageStore |
KahaDBStore.createTopicMessageStore(ActiveMQTopic destination) |
TopicMessageStore |
TempKahaDBStore.createTopicMessageStore(ActiveMQTopic destination) |
TopicMessageStore |
KahaDBPersistenceAdapter.createTopicMessageStore(ActiveMQTopic destination) |
TopicMessageStore |
MultiKahaDBPersistenceAdapter.createTopicMessageStore(ActiveMQTopic destination) |
void |
KahaDBStore.removeTopicMessageStore(ActiveMQTopic destination)
Cleanup method to remove any state associated with the given destination
This method does not stop the message store (it might not be cached).
|
void |
TempKahaDBStore.removeTopicMessageStore(ActiveMQTopic destination)
Cleanup method to remove any state associated with the given destination
This method does not stop the message store (it might not be cached).
|
void |
KahaDBPersistenceAdapter.removeTopicMessageStore(ActiveMQTopic destination) |
void |
MultiKahaDBPersistenceAdapter.removeTopicMessageStore(ActiveMQTopic destination) |
Modifier and Type | Method and Description |
---|---|
TopicMessageStore |
MemoryPersistenceAdapter.createTopicMessageStore(ActiveMQTopic destination) |
void |
MemoryPersistenceAdapter.removeTopicMessageStore(ActiveMQTopic destination)
Cleanup method to remove any state associated with the given destination
|
Copyright © 2005–2016 The Apache Software Foundation. All rights reserved.