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.store |
The APIs which need to be implemented for persistent message stores for durable messaging
|
org.apache.activemq.store.amq |
The default Store implementation for ActiveMQ
|
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.kahadaptor |
kaha implementation of message persistence for the broker
|
org.apache.activemq.store.memory |
VM based implementation of message persistence
|
org.apache.activemq.util |
Some utility classes
|
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,
String clientId,
SubscriptionInfo subInfo,
Subscription subscription)
Constructor
|
Modifier and Type | Method and Description |
---|---|
abstract SubscriptionInfo[] |
DestinationFactory.getAllDurableSubscriptions(ActiveMQTopic topic)
Lists all the durable subscirptions for a given destination.
|
SubscriptionInfo[] |
DestinationFactoryImpl.getAllDurableSubscriptions(ActiveMQTopic topic) |
Modifier and Type | Method and Description |
---|---|
ConsumerInfo |
TopicRegion.createInactiveConsumerInfo(SubscriptionInfo info) |
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(String clientId,
String subscriptionName)
Finds the subscriber entry for the given consumer info
|
SubscriptionInfo |
TopicMessageStore.lookupSubscription(String clientId,
String subscriptionName)
Finds the subscriber entry for the given consumer info
|
SubscriptionInfo |
ProxyTopicMessageStore.lookupSubscription(String clientId,
String subscriptionName) |
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.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 |
ProxyTopicMessageStore.addSubsciption(SubscriptionInfo subscriptionInfo,
boolean retroactive) |
void |
ReferenceStoreAdapter.recoverSubscription(SubscriptionInfo info)
Recover particular subscription.
|
Modifier and Type | Method and Description |
---|---|
SubscriptionInfo[] |
AMQTopicMessageStore.getAllSubscriptions() |
SubscriptionInfo |
AMQTopicMessageStore.lookupSubscription(String clientId,
String subscriptionName) |
Modifier and Type | Method and Description |
---|---|
void |
AMQTopicMessageStore.addSubsciption(SubscriptionInfo subscriptionInfo,
boolean retroactive) |
Modifier and Type | Method and Description |
---|---|
SubscriptionInfo[] |
JDBCAdapter.doGetAllSubscriptions(TransactionContext c,
ActiveMQDestination destination) |
SubscriptionInfo |
JDBCAdapter.doGetSubscriberEntry(TransactionContext c,
ActiveMQDestination destination,
String clientId,
String subscriptionName) |
SubscriptionInfo[] |
JDBCTopicMessageStore.getAllSubscriptions() |
SubscriptionInfo |
JDBCTopicMessageStore.lookupSubscription(String clientId,
String subscriptionName) |
Modifier and Type | Method and Description |
---|---|
void |
JDBCTopicMessageStore.addSubsciption(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,
String clientId,
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(String clientId,
String subscriptionName) |
Modifier and Type | Method and Description |
---|---|
void |
JournalTopicMessageStore.addSubsciption(SubscriptionInfo subscriptionInfo,
boolean retroactive) |
Modifier and Type | Method and Description |
---|---|
SubscriptionInfo[] |
KahaTopicReferenceStore.getAllSubscriptions() |
SubscriptionInfo[] |
KahaTopicMessageStore.getAllSubscriptions() |
SubscriptionInfo |
KahaTopicReferenceStore.lookupSubscription(String clientId,
String subscriptionName) |
SubscriptionInfo |
KahaTopicMessageStore.lookupSubscription(String clientId,
String subscriptionName) |
Modifier and Type | Method and Description |
---|---|
void |
KahaTopicReferenceStore.addSubsciption(SubscriptionInfo info,
boolean retroactive) |
void |
KahaTopicMessageStore.addSubsciption(SubscriptionInfo info,
boolean retroactive) |
protected void |
KahaReferenceStoreAdapter.addSubscriberState(SubscriptionInfo info) |
void |
KahaReferenceStoreAdapter.recoverSubscription(SubscriptionInfo info) |
protected void |
KahaReferenceStoreAdapter.removeSubscriberState(SubscriptionInfo info) |
Constructor and Description |
---|
KahaTopicMessageStore(Store store,
MapContainer<MessageId,Message> messageContainer,
ListContainer<TopicSubAck> ackContainer,
MapContainer<String,SubscriptionInfo> subsContainer,
ActiveMQDestination destination) |
KahaTopicReferenceStore(Store store,
KahaReferenceStoreAdapter adapter,
MapContainer<MessageId,ReferenceRecord> messageContainer,
ListContainer<TopicSubAck> ackContainer,
MapContainer<String,SubscriptionInfo> subsContainer,
ActiveMQDestination destination) |
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.addSubsciption(SubscriptionInfo info,
boolean retroactive) |
Constructor and Description |
---|
MemoryTopicMessageStore(ActiveMQDestination destination,
Map<MessageId,Message> messageTable,
Map<SubscriptionKey,SubscriptionInfo> subscriberDatabase) |
Constructor and Description |
---|
SubscriptionKey(SubscriptionInfo info) |
Copyright © 2005–2015 The Apache Software Foundation. All rights reserved.