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 ConcurrentHashMap<SubscriptionKey,DurableTopicSubscription> |
TopicRegion.durableSubscriptions |
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,
String clientId,
String subscriberName,
int maxBatchSize,
DurableTopicSubscription subscription) |
Modifier and Type | Method and Description |
---|---|
void |
PolicyEntry.configure(Broker broker,
SystemUsage memoryManager,
DurableTopicSubscription sub) |
PendingMessageCursor |
PendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
String clientId,
String name,
int maxBatchSize,
DurableTopicSubscription sub)
Retrieve the configured pending message storage cursor;
|
PendingMessageCursor |
StorePendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
String clientId,
String name,
int maxBatchSize,
DurableTopicSubscription sub)
Retrieve the configured pending message storage cursor;
|
PendingMessageCursor |
VMPendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
String clientId,
String name,
int maxBatchSize,
DurableTopicSubscription sub)
Retrieve the configured pending message storage cursor;
|
PendingMessageCursor |
FilePendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
String clientId,
String name,
int maxBatchSize,
DurableTopicSubscription sub)
Retrieve the configured pending message storage cursor;
|
Copyright © 2005–2016 The Apache Software Foundation. All rights reserved.