Uses of Interface
org.codehaus.activemq.service.Subscription

Packages that use Subscription
org.codehaus.activemq.service The core services which make up the JMS Message Broker such as the Store, MessageContainer and MessageContainerManager  
org.codehaus.activemq.service.impl Default implementations of the services  
org.codehaus.activemq.store The APIs which need to be implemented for persistent message stores for durable messaging  
org.codehaus.activemq.store.bdb Message persistence implemented using Berkeley DB Java Edition  
org.codehaus.activemq.store.bdbn Message persistence implemented using Berkeley DB, native C version  
org.codehaus.activemq.store.cache   
org.codehaus.activemq.store.jdbc Message persistence implemented using JDBC  
org.codehaus.activemq.store.jdbm Message persistence implemented using JDBM which is the default persistence mechanism shipped with Geronimo (due to its BSD licence)  
org.codehaus.activemq.store.vm VM based implementation of message persistence  
 

Uses of Subscription in org.codehaus.activemq.service
 

Methods in org.codehaus.activemq.service that return Subscription
 Subscription SubscriptionContainer.getSubscription(String consumerId)
          Gets the current subscription for the given consumerId if it is available
 Subscription SubscriptionContainer.removeSubscription(String consumerId)
           
 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
 

Methods in org.codehaus.activemq.service with parameters of type Subscription
 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
 void Dispatcher.addActiveSubscription(BrokerClient client, Subscription sub)
          Add an active subscription
 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.recoverSubscription(Subscription subscription)
          A durable subscription has started so recovery any messages that are required.
 void TopicMessageContainer.storeSubscription(ConsumerInfo info, Subscription subscription)
          Stores the persistence details in the database
 

Uses of Subscription in org.codehaus.activemq.service.impl
 

Classes in org.codehaus.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.codehaus.activemq.service.impl that return Subscription
 Subscription SubscriptionContainerImpl.getSubscription(String consumerId)
           
 Subscription SubscriptionContainerImpl.removeSubscription(String consumerId)
           
 Subscription SubscriptionContainerImpl.makeSubscription(Dispatcher dispatcher, BrokerClient client, ConsumerInfo info, Filter filter)
           
protected  Subscription SubscriptionContainerImpl.createSubscription(Dispatcher dispatcher, BrokerClient client, ConsumerInfo info, Filter filter)
           
protected  Subscription DurableTopicSubscriptionContainerImpl.createSubscription(Dispatcher dispatcher, BrokerClient client, ConsumerInfo info, Filter filter)
           
 

Methods in org.codehaus.activemq.service.impl with parameters of type Subscription
protected  void DurableQueueMessageContainerManager.processSubscription(Subscription subscription, QueueMessageContainer container)
           
 void DurableTopicMessageContainer.setLastAcknowledgedMessageID(Subscription subscription, MessageIdentity messageIdentity)
           
 void DurableTopicMessageContainer.recoverSubscription(Subscription subscription)
           
 void DurableTopicMessageContainer.storeSubscription(ConsumerInfo info, Subscription subscription)
           
protected  void MessageContainerManagerSupport.updateAcknowledgeStats(BrokerClient client, Subscription subscription)
          Updates the message acknowledgement stats
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 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
 void DispatcherImpl.addActiveSubscription(BrokerClient client, Subscription sub)
          Add an active subscription
 void DispatcherImpl.removeActiveSubscription(BrokerClient client, Subscription sub)
          remove an active subscription
 void DispatchWorker.addActiveSubscription(BrokerClient client, Subscription sub)
          Add an active subscription
 void DispatchWorker.removeActiveSubscription(BrokerClient client, Subscription sub)
          remove an active subscription
protected  boolean DispatchWorker.dispatchMessages(Subscription subscription, boolean dispatched)
           
 

Uses of Subscription in org.codehaus.activemq.store
 

Methods in org.codehaus.activemq.store with parameters of type Subscription
 void TopicMessageStore.setLastAcknowledgedMessageIdentity(Subscription subscription, MessageIdentity messageIdentity)
          Stores the last acknowledged messgeID for the given subscription so that we can recover and commence dispatching messages from the last checkpoint
 void TopicMessageStore.recoverSubscription(Subscription subscription, MessageIdentity lastDispatchedMessage)
          For the new subcription find the last acknowledged message ID and then find any new messages since then and dispatch them to the subscription.
 

Uses of Subscription in org.codehaus.activemq.store.bdb
 

Methods in org.codehaus.activemq.store.bdb with parameters of type Subscription
 void BDbTopicMessageStore.setLastAcknowledgedMessageIdentity(Subscription subscription, MessageIdentity messageIdentity)
           
 void BDbTopicMessageStore.recoverSubscription(Subscription subscription, MessageIdentity lastDispatchedMessage)
           
protected  com.sleepycat.je.DatabaseEntry BDbTopicMessageStore.getLastAcknowledgedMessageID(Subscription subscription, MessageIdentity lastDispatchedMessage)
           
protected  com.sleepycat.je.DatabaseEntry BDbTopicMessageStore.doSetLastAcknowledgedMessageIdentity(Subscription subscription, MessageIdentity messageIdentity)
           
 

Uses of Subscription in org.codehaus.activemq.store.bdbn
 

Methods in org.codehaus.activemq.store.bdbn with parameters of type Subscription
 void BDbTopicMessageStore.setLastAcknowledgedMessageIdentity(Subscription subscription, MessageIdentity messageIdentity)
           
 void BDbTopicMessageStore.recoverSubscription(Subscription subscription, MessageIdentity lastDispatchedMessage)
           
 

Uses of Subscription in org.codehaus.activemq.store.cache
 

Methods in org.codehaus.activemq.store.cache with parameters of type Subscription
 void CacheTopicMessageStore.setLastAcknowledgedMessageIdentity(Subscription subscription, MessageIdentity messageIdentity)
           
 void CacheTopicMessageStore.recoverSubscription(Subscription subscription, MessageIdentity lastDispatchedMessage)
           
 

Uses of Subscription in org.codehaus.activemq.store.jdbc
 

Methods in org.codehaus.activemq.store.jdbc with parameters of type Subscription
 void JDBCTopicMessageStore.setLastAcknowledgedMessageIdentity(Subscription subscription, MessageIdentity messageIdentity)
           
 void JDBCTopicMessageStore.recoverSubscription(Subscription subscription, MessageIdentity lastDispatchedMessage)
           
 

Uses of Subscription in org.codehaus.activemq.store.jdbm
 

Methods in org.codehaus.activemq.store.jdbm with parameters of type Subscription
 void JdbmTopicMessageStore.setLastAcknowledgedMessageIdentity(Subscription subscription, MessageIdentity messageIdentity)
           
 void JdbmTopicMessageStore.recoverSubscription(Subscription subscription, MessageIdentity lastDispatchedMessage)
           
protected  MessageIdentity JdbmTopicMessageStore.getLastAcknowledgedMessageIdentity(Subscription subscription)
           
 

Uses of Subscription in org.codehaus.activemq.store.vm
 

Methods in org.codehaus.activemq.store.vm with parameters of type Subscription
 void VMTopicMessageStore.setLastAcknowledgedMessageIdentity(Subscription subscription, MessageIdentity messageIdentity)
           
 void VMTopicMessageStore.recoverSubscription(Subscription subscription, MessageIdentity lastDispatchedMessage)
           
 



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