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.network |
Support for federated networks of brokers.
|
org.apache.activemq.store |
The APIs which need to be implemented for persistent message stores for durable messaging
|
org.apache.activemq.store.memory |
VM based implementation of message persistence
|
org.apache.activemq.transport.mqtt.strategy | |
org.apache.activemq.util |
Modifier and Type | Field and Description |
---|---|
protected SubscriptionInfo |
InactiveDurableSubscriptionView.subscriptionInfo |
Modifier and Type | Method and Description |
---|---|
protected void |
ManagedRegionBroker.addInactiveSubscription(SubscriptionKey key,
SubscriptionInfo info,
Subscription subscription) |
Constructor and Description |
---|
InactiveDurableSubscriptionView(ManagedRegionBroker broker,
BrokerService brokerService,
String clientId,
SubscriptionInfo subInfo,
Subscription subscription)
Constructor
|
Modifier and Type | Method and Description |
---|---|
SubscriptionInfo[] |
DestinationFactoryImpl.getAllDurableSubscriptions(ActiveMQTopic topic) |
abstract SubscriptionInfo[] |
DestinationFactory.getAllDurableSubscriptions(ActiveMQTopic topic)
Lists all the durable subscirptions for a given destination.
|
Modifier and Type | Method and Description |
---|---|
ConsumerInfo |
TopicRegion.createInactiveConsumerInfo(SubscriptionInfo info) |
Modifier and Type | Method and Description |
---|---|
SubscriptionInfo |
DemandSubscription.getLocalDurableSubscriber() |
Modifier and Type | Method and Description |
---|---|
Set<SubscriptionInfo> |
DemandSubscription.getDurableRemoteSubs() |
Modifier and Type | Method and Description |
---|---|
void |
DemandSubscription.setLocalDurableSubscriber(SubscriptionInfo localDurableSubscriber) |
Modifier and Type | Method and Description |
---|---|
SubscriptionInfo[] |
TopicMessageStore.getAllSubscriptions()
Lists all the durable subscriptions for a given destination.
|
SubscriptionInfo[] |
ProxyTopicMessageStore.getAllSubscriptions() |
SubscriptionInfo[] |
TopicReferenceStore.getAllSubscriptions()
Lists all the durable subscriptions for a given destination.
|
SubscriptionInfo |
TopicMessageStore.lookupSubscription(String clientId,
String subscriptionName)
Finds the subscriber entry for the given consumer info
|
SubscriptionInfo |
ProxyTopicMessageStore.lookupSubscription(String clientId,
String subscriptionName) |
SubscriptionInfo |
TopicReferenceStore.lookupSubscription(String clientId,
String subscriptionName)
Finds the subscriber entry for the given consumer info
|
Modifier and Type | Method and Description |
---|---|
static List<SubscriptionInfo> |
PersistenceAdapterSupport.listSubscriptions(PersistenceAdapter adapter,
String clientId)
Searches the set of subscriptions from the given persistence adapter and returns all those
that belong to the given ClientId value.
|
Modifier and Type | Method and Description |
---|---|
void |
TopicReferenceStore.addSubsciption(SubscriptionInfo subscriptionInfo,
boolean retroactive)
Inserts the subscriber info due to a subscription change If this is
a new subscription and the retroactive is false, then the last message
sent to the topic should be set as the last message acknowledged by they
new subscription.
|
void |
TopicMessageStore.addSubscription(SubscriptionInfo subscriptionInfo,
boolean retroactive)
Inserts the subscriber info due to a subscription change If this is
a new subscription and the retroactive is false, then the last message
sent to the topic should be set as the last message acknowledged by they
new subscription.
|
void |
ProxyTopicMessageStore.addSubscription(SubscriptionInfo subscriptionInfo,
boolean retroactive) |
Modifier and Type | Method and Description |
---|---|
SubscriptionInfo[] |
MemoryTopicMessageStore.getAllSubscriptions() |
SubscriptionInfo |
MemoryTopicMessageStore.lookupSubscription(String clientId,
String subscriptionName) |
Modifier and Type | Method and Description |
---|---|
protected static Map<SubscriptionKey,SubscriptionInfo> |
MemoryTopicMessageStore.makeSubscriptionInfoMap() |
Modifier and Type | Method and Description |
---|---|
void |
MemoryTopicMessageStore.addSubscription(SubscriptionInfo info,
boolean retroactive) |
Constructor and Description |
---|
MemoryTopicMessageStore(ActiveMQDestination destination,
Map<MessageId,Message> messageTable,
Map<SubscriptionKey,SubscriptionInfo> subscriberDatabase) |
Modifier and Type | Method and Description |
---|---|
protected List<SubscriptionInfo> |
AbstractMQTTSubscriptionStrategy.lookupSubscription(String clientId) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractMQTTSubscriptionStrategy.deleteDurableSubs(List<SubscriptionInfo> subs) |
protected void |
AbstractMQTTSubscriptionStrategy.restoreDurableSubs(List<SubscriptionInfo> subs) |
Constructor and Description |
---|
SubscriptionKey(SubscriptionInfo info) |
Copyright © 2005–2024 The Apache Software Foundation. All rights reserved.