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.jdbc |
Message persistence implemented using JDBC
|
org.apache.activemq.store.jdbc.adapter |
Implements database/driver apapters to compensate for the
wide differences in the BLOB handing of JDBC drivers.
|
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
|
org.apache.activemq.transport.mqtt |
A Broker side implementation of the MQTT 3.1 protocol - see http://mqtt.org/
|
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,
java.lang.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 |
---|---|
java.util.Set<SubscriptionInfo> |
DemandSubscription.getDurableRemoteSubs() |
Modifier and Type | Method and Description |
---|---|
void |
DemandSubscription.setLocalDurableSubscriber(SubscriptionInfo localDurableSubscriber) |
Modifier and Type | Method and Description |
---|---|
SubscriptionInfo[] |
TopicReferenceStore.getAllSubscriptions()
Lists all the durable subscirptions for a given destination.
|
SubscriptionInfo[] |
TopicMessageStore.getAllSubscriptions()
Lists all the durable subscriptions for a given destination.
|
SubscriptionInfo[] |
ProxyTopicMessageStore.getAllSubscriptions() |
SubscriptionInfo |
TopicReferenceStore.lookupSubscription(java.lang.String clientId,
java.lang.String subscriptionName)
Finds the subscriber entry for the given consumer info
|
SubscriptionInfo |
TopicMessageStore.lookupSubscription(java.lang.String clientId,
java.lang.String subscriptionName)
Finds the subscriber entry for the given consumer info
|
SubscriptionInfo |
ProxyTopicMessageStore.lookupSubscription(java.lang.String clientId,
java.lang.String subscriptionName) |
Modifier and Type | Method and Description |
---|---|
static java.util.List<SubscriptionInfo> |
PersistenceAdapterSupport.listSubscriptions(PersistenceAdapter pa,
java.lang.String clientId) |
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[] |
JDBCAdapter.doGetAllSubscriptions(TransactionContext c,
ActiveMQDestination destination) |
SubscriptionInfo |
JDBCAdapter.doGetSubscriberEntry(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName) |
SubscriptionInfo[] |
JDBCTopicMessageStore.getAllSubscriptions() |
SubscriptionInfo |
JDBCTopicMessageStore.lookupSubscription(java.lang.String clientId,
java.lang.String subscriptionName) |
Modifier and Type | Method and Description |
---|---|
void |
JDBCTopicMessageStore.addSubscription(SubscriptionInfo subscriptionInfo,
boolean retroactive) |
void |
JDBCAdapter.doSetSubscriberEntry(TransactionContext c,
SubscriptionInfo subscriptionInfo,
boolean retroactive,
boolean isPrioritizeMessages) |
Modifier and Type | Method and Description |
---|---|
SubscriptionInfo[] |
DefaultJDBCAdapter.doGetAllSubscriptions(TransactionContext c,
ActiveMQDestination destination) |
SubscriptionInfo |
DefaultJDBCAdapter.doGetSubscriberEntry(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultJDBCAdapter.doSetSubscriberEntry(TransactionContext c,
SubscriptionInfo info,
boolean retroactive,
boolean isPrioritizedMessages) |
Modifier and Type | Method and Description |
---|---|
SubscriptionInfo[] |
JournalTopicMessageStore.getAllSubscriptions() |
SubscriptionInfo |
JournalTopicMessageStore.lookupSubscription(java.lang.String clientId,
java.lang.String subscriptionName) |
Modifier and Type | Method and Description |
---|---|
void |
JournalTopicMessageStore.addSubscription(SubscriptionInfo subscriptionInfo,
boolean retroactive) |
Modifier and Type | Method and Description |
---|---|
SubscriptionInfo[] |
MemoryTopicMessageStore.getAllSubscriptions() |
SubscriptionInfo |
MemoryTopicMessageStore.lookupSubscription(java.lang.String clientId,
java.lang.String subscriptionName) |
Modifier and Type | Method and Description |
---|---|
protected static java.util.Map<SubscriptionKey,SubscriptionInfo> |
MemoryTopicMessageStore.makeSubscriptionInfoMap() |
Modifier and Type | Method and Description |
---|---|
void |
MemoryTopicMessageStore.addSubscription(SubscriptionInfo info,
boolean retroactive) |
Constructor and Description |
---|
MemoryTopicMessageStore(ActiveMQDestination destination,
java.util.Map<MessageId,Message> messageTable,
java.util.Map<SubscriptionKey,SubscriptionInfo> subscriberDatabase) |
Modifier and Type | Method and Description |
---|---|
void |
MQTTProtocolConverter.deleteDurableSubs(java.util.List<SubscriptionInfo> subs) |
void |
MQTTProtocolConverter.restoreDurableSubs(java.util.List<SubscriptionInfo> subs) |
Constructor and Description |
---|
SubscriptionKey(SubscriptionInfo info) |
Copyright © 2005-2014 Red Hat, Inc.. All Rights Reserved.