|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |
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)
|
|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |