Package | Description |
---|---|
org.apache.activemq.broker.jmx |
JMX MBeans for the broker and its core connectors.
|
org.apache.activemq.broker.region |
Region abstraction and implementations in the Broker.
|
org.apache.activemq.store.journal |
Message persistence using a high performance transaction log via the Journal interface.
|
org.apache.activemq.store.memory |
VM based implementation of message persistence
|
Modifier and Type | Method and Description |
---|---|
protected void |
ManagedRegionBroker.addInactiveSubscription(SubscriptionKey key,
SubscriptionInfo info,
Subscription subscription) |
protected void |
ManagedRegionBroker.registerSubscription(ObjectName key,
ConsumerInfo info,
SubscriptionKey subscriptionKey,
SubscriptionView view) |
Modifier and Type | Field and Description |
---|---|
protected ConcurrentHashMap<SubscriptionKey,DurableTopicSubscription> |
TopicRegion.durableSubscriptions |
Modifier and Type | Method and Description |
---|---|
SubscriptionKey |
DurableTopicSubscription.getSubscriptionKey() |
Modifier and Type | Method and Description |
---|---|
void |
Topic.deleteSubscription(ConnectionContext context,
SubscriptionKey key) |
boolean |
TopicRegion.durableSubscriptionExists(SubscriptionKey key) |
Modifier and Type | Method and Description |
---|---|
protected void |
JournalTopicMessageStore.acknowledge(MessageId messageId,
org.apache.activeio.journal.RecordLocation location,
SubscriptionKey key) |
Modifier and Type | Method and Description |
---|---|
protected static Map<SubscriptionKey,org.apache.activemq.store.memory.MemoryTopicSub> |
MemoryTopicMessageStore.makeSubMap() |
protected static Map<SubscriptionKey,SubscriptionInfo> |
MemoryTopicMessageStore.makeSubscriptionInfoMap() |
Constructor and Description |
---|
MemoryTopicMessageStore(ActiveMQDestination destination,
Map<MessageId,Message> messageTable,
Map<SubscriptionKey,SubscriptionInfo> subscriberDatabase) |
Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.