Uses of Class
org.apache.activemq.util.SubscriptionKey
-
Packages that use SubscriptionKey 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.virtual Implementation classes for Virtual Destinationsorg.apache.activemq.store The APIs which need to be implemented for persistent message stores for durable messagingorg.apache.activemq.store.memory VM based implementation of message persistence -
-
Uses of SubscriptionKey in org.apache.activemq.broker.jmx
Methods in org.apache.activemq.broker.jmx with parameters of type SubscriptionKey Modifier and Type Method Description protected voidManagedRegionBroker. addInactiveSubscription(SubscriptionKey key, org.apache.activemq.command.SubscriptionInfo info, Subscription subscription)protected voidManagedRegionBroker. registerSubscription(ObjectName key, org.apache.activemq.command.ConsumerInfo info, SubscriptionKey subscriptionKey, SubscriptionView view) -
Uses of SubscriptionKey in org.apache.activemq.broker.region
Fields in org.apache.activemq.broker.region with type parameters of type SubscriptionKey Modifier and Type Field Description protected ConcurrentMap<SubscriptionKey,DurableTopicSubscription>TopicRegion. durableSubscriptionsMethods in org.apache.activemq.broker.region that return SubscriptionKey Modifier and Type Method Description SubscriptionKeyDurableTopicSubscription. getSubscriptionKey()Methods in org.apache.activemq.broker.region that return types with arguments of type SubscriptionKey Modifier and Type Method Description Map<SubscriptionKey,DurableTopicSubscription>TopicRegion. getDurableSubscriptions()Map<SubscriptionKey,DurableTopicSubscription>Topic. getDurableTopicSubs()Methods in org.apache.activemq.broker.region with parameters of type SubscriptionKey Modifier and Type Method Description voidDestinationFilter. deleteSubscription(ConnectionContext context, SubscriptionKey key)voidTopic. deleteSubscription(ConnectionContext context, SubscriptionKey key)booleanTopicRegion. durableSubscriptionExists(SubscriptionKey key)DurableTopicSubscriptionTopicRegion. getDurableSubscription(SubscriptionKey key) -
Uses of SubscriptionKey in org.apache.activemq.broker.region.virtual
Methods in org.apache.activemq.broker.region.virtual with parameters of type SubscriptionKey Modifier and Type Method Description voidMappedQueueFilter. deleteSubscription(ConnectionContext context, SubscriptionKey key) -
Uses of SubscriptionKey in org.apache.activemq.store
Methods in org.apache.activemq.store that return types with arguments of type SubscriptionKey Modifier and Type Method Description Map<SubscriptionKey,List<org.apache.activemq.command.Message>>ProxyTopicMessageStore. recoverExpired(Set<SubscriptionKey> subs, int max, MessageRecoveryListener listener)Map<SubscriptionKey,List<org.apache.activemq.command.Message>>TopicMessageStore. recoverExpired(Set<SubscriptionKey> subs, int maxBrowse, MessageRecoveryListener listener)Iterates over the pending messages in a topic and recovers any expired messages found for each of the subscriptions up to the maximum number of messages to search.Method parameters in org.apache.activemq.store with type arguments of type SubscriptionKey Modifier and Type Method Description Map<SubscriptionKey,List<org.apache.activemq.command.Message>>ProxyTopicMessageStore. recoverExpired(Set<SubscriptionKey> subs, int max, MessageRecoveryListener listener)Map<SubscriptionKey,List<org.apache.activemq.command.Message>>TopicMessageStore. recoverExpired(Set<SubscriptionKey> subs, int maxBrowse, MessageRecoveryListener listener)Iterates over the pending messages in a topic and recovers any expired messages found for each of the subscriptions up to the maximum number of messages to search. -
Uses of SubscriptionKey in org.apache.activemq.store.memory
Methods in org.apache.activemq.store.memory that return types with arguments of type SubscriptionKey Modifier and Type Method Description protected static Map<SubscriptionKey,org.apache.activemq.store.memory.MemoryTopicSub>MemoryTopicMessageStore. makeSubMap()protected static Map<SubscriptionKey,org.apache.activemq.command.SubscriptionInfo>MemoryTopicMessageStore. makeSubscriptionInfoMap()Map<SubscriptionKey,List<org.apache.activemq.command.Message>>MemoryTopicMessageStore. recoverExpired(Set<SubscriptionKey> subs, int max, MessageRecoveryListener listener)Method parameters in org.apache.activemq.store.memory with type arguments of type SubscriptionKey Modifier and Type Method Description Map<SubscriptionKey,List<org.apache.activemq.command.Message>>MemoryTopicMessageStore. recoverExpired(Set<SubscriptionKey> subs, int max, MessageRecoveryListener listener)
-