| 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.