Uses of Interface
org.activemq.service.Subscription

Packages that use Subscription
org.activemq.service The core services which make up the JMS Message Broker such as the Store, MessageContainer and MessageContainerManager 
org.activemq.service.impl Default implementations of the services 
 

Uses of Subscription in org.activemq.service
 

Methods in org.activemq.service that return Subscription
 Subscription SubscriptionContainer.getSubscription(String consumerId)
          Gets the current subscription for the given consumerId if it is available
 Subscription SubscriptionContainer.makeSubscription(Dispatcher dispatcher, BrokerClient client, ConsumerInfo info, Filter filter)
          Creates a subscription (which could be a previous subscription reconecting) and adds it to this container
 Subscription SubscriptionContainer.removeSubscription(String consumerId)
           
 

Methods in org.activemq.service with parameters of type Subscription
 void Dispatcher.addActiveSubscription(BrokerClient client, Subscription sub)
          Add an active subscription
 void TopicMessageContainer.recoverSubscription(Subscription subscription)
          A durable subscription has started so recovery any messages that are required.
 void Dispatcher.removeActiveSubscription(BrokerClient client, Subscription sub)
          remove an active subscription
 void TopicMessageContainer.setLastAcknowledgedMessageID(Subscription subscription, MessageIdentity messageIdentity)
          Sets the last acknowleged message ID for the given subscriber in this container so that if we shut down and recover we know where to start replaying messages from.
 void TopicMessageContainer.storeSubscription(ConsumerInfo info, Subscription subscription)
          Stores the persistence details in the database
 void Dispatcher.wakeup(Subscription sub)
          Called to indicate that there is work to do on a Subscription this will wake up a Dispatch Worker if it is waiting for messages to dispatch
 

Uses of Subscription in org.activemq.service.impl
 

Classes in org.activemq.service.impl that implement Subscription
 class DurableTopicSubscription
          Represents a durable topic subscription where the consumer has a unique clientID used to persist the messages across both Broker restarts and JMS client restarts
 class SubscriptionImpl
          A Subscription holds messages to be dispatched to a a Client Consumer
 

Methods in org.activemq.service.impl that return Subscription
protected  Subscription DurableTopicSubscriptionContainerImpl.createSubscription(Dispatcher dispatcher, BrokerClient client, ConsumerInfo info, Filter filter)
           
protected  Subscription SubscriptionContainerImpl.createSubscription(Dispatcher dispatcher, BrokerClient client, ConsumerInfo info, Filter filter)
           
 Subscription SubscriptionContainerImpl.getSubscription(String consumerId)
           
 Subscription SubscriptionContainerImpl.makeSubscription(Dispatcher dispatcher, BrokerClient client, ConsumerInfo info, Filter filter)
           
 Subscription SubscriptionContainerImpl.removeSubscription(String consumerId)
           
 

Methods in org.activemq.service.impl with parameters of type Subscription
 void DispatchWorker.addActiveSubscription(BrokerClient client, Subscription sub)
          Add an active subscription
 void DispatcherImpl.addActiveSubscription(BrokerClient client, Subscription sub)
          Add an active subscription
protected  boolean DispatchWorker.dispatchMessages(Subscription subscription, boolean dispatched)
           
protected  void DurableQueueMessageContainerManager.processSubscription(Subscription subscription, QueueMessageContainer container)
           
 void DurableTopicMessageContainer.recoverSubscription(Subscription subscription)
           
protected  void DurableTopicMessageContainerManager.recoverSubscriptions(Subscription subscription)
          This method is called when a new durable subscription is started and so we need to go through each matching message container and dispatch any matching messages that may be outstanding
 void DispatchWorker.removeActiveSubscription(BrokerClient client, Subscription sub)
          remove an active subscription
 void DispatcherImpl.removeActiveSubscription(BrokerClient client, Subscription sub)
          remove an active subscription
 void DurableTopicMessageContainer.setLastAcknowledgedMessageID(Subscription subscription, MessageIdentity messageIdentity)
           
 void DurableTopicMessageContainer.storeSubscription(ConsumerInfo info, Subscription subscription)
           
protected  void MessageContainerManagerSupport.updateAcknowledgeStats(BrokerClient client, Subscription subscription)
          Updates the message acknowledgement stats
 void DispatcherImpl.wakeup(Subscription sub)
          Called to indicate that there is work to do on a Subscription this will wake up a Dispatch Worker if it is waiting for messages to dispatch
 



Copyright © 2004-2009 Protique, Ltd.. All Rights Reserved.