| 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.broker.region.cursors | 
 Cursors used to page persistent messages into the broker from the store 
 | 
| org.apache.activemq.broker.region.policy | 
 The policies which can be associated with a particular destination or wildcard. 
 | 
| Modifier and Type | Field and Description | 
|---|---|
protected DurableTopicSubscription | 
DurableSubscriptionView.durableSub  | 
| Modifier and Type | Field and Description | 
|---|---|
protected java.util.concurrent.ConcurrentHashMap<SubscriptionKey,DurableTopicSubscription> | 
TopicRegion.durableSubscriptions  | 
| Modifier and Type | Method and Description | 
|---|---|
java.util.Map<SubscriptionKey,DurableTopicSubscription> | 
Topic.getDurableTopicSubs()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
Topic.activate(ConnectionContext context,
        DurableTopicSubscription subscription)  | 
void | 
Topic.deactivate(ConnectionContext context,
          DurableTopicSubscription sub)  | 
| Constructor and Description | 
|---|
StoreDurableSubscriberCursor(Broker broker,
                            java.lang.String clientId,
                            java.lang.String subscriberName,
                            int maxBatchSize,
                            DurableTopicSubscription subscription)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
PolicyEntry.configure(Broker broker,
         SystemUsage memoryManager,
         DurableTopicSubscription sub)  | 
PendingMessageCursor | 
VMPendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
                                 java.lang.String clientId,
                                 java.lang.String name,
                                 int maxBatchSize,
                                 DurableTopicSubscription sub)
Retrieve the configured pending message storage cursor; 
 | 
PendingMessageCursor | 
StorePendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
                                 java.lang.String clientId,
                                 java.lang.String name,
                                 int maxBatchSize,
                                 DurableTopicSubscription sub)
Retrieve the configured pending message storage cursor; 
 | 
PendingMessageCursor | 
PendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
                                 java.lang.String clientId,
                                 java.lang.String name,
                                 int maxBatchSize,
                                 DurableTopicSubscription sub)
Retrieve the configured pending message storage cursor; 
 | 
PendingMessageCursor | 
FilePendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
                                 java.lang.String clientId,
                                 java.lang.String name,
                                 int maxBatchSize,
                                 DurableTopicSubscription sub)
Retrieve the configured pending message storage cursor; 
 | 
Copyright © 2005-2013 Red Hat, Inc.. All Rights Reserved.