Overview | Package | Class | Use | Tree | Deprecated | Index | Help
PREV NEXT | FRAMES NO FRAMES

## 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)`

Overview | Package | Class | Use | Tree | Deprecated | Index | Help
PREV NEXT | FRAMES NO FRAMES

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