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