org.activemq.service.impl
Class SubscriptionContainerImpl
java.lang.Object
org.activemq.service.impl.SubscriptionContainerImpl
- All Implemented Interfaces:
- SubscriptionContainer
- Direct Known Subclasses:
- DurableTopicSubscriptionContainerImpl
public class SubscriptionContainerImpl
- extends Object
- implements SubscriptionContainer
A default RAM only implementation of the SubscriptionContainer
- Version:
- $Revision: 1.1.1.1 $
SubscriptionContainerImpl
public SubscriptionContainerImpl(RedeliveryPolicy redeliveryPolicy,
DeadLetterPolicy deadLetterPolicy)
SubscriptionContainerImpl
public SubscriptionContainerImpl(Map subscriptions,
RedeliveryPolicy redeliveryPolicy,
DeadLetterPolicy deadLetterPolicy)
toString
public String toString()
- Overrides:
toString
in class Object
getRedeliveryPolicy
public RedeliveryPolicy getRedeliveryPolicy()
getDeadLetterPolicy
public DeadLetterPolicy getDeadLetterPolicy()
getSubscription
public Subscription getSubscription(String consumerId)
- Description copied from interface:
SubscriptionContainer
- Gets the current subscription for the given consumerId if it is available
- Specified by:
getSubscription
in interface SubscriptionContainer
- Returns:
removeSubscription
public Subscription removeSubscription(String consumerId)
- Specified by:
removeSubscription
in interface SubscriptionContainer
getSubscriptions
public Set getSubscriptions(ActiveMQDestination destination)
- Specified by:
getSubscriptions
in interface SubscriptionContainer
- Returns:
- a collection of subscriptions for the given destination
subscriptionIterator
public Iterator subscriptionIterator()
- Specified by:
subscriptionIterator
in interface SubscriptionContainer
- Returns:
- an iterator through the subscriptions
makeSubscription
public Subscription makeSubscription(Dispatcher dispatcher,
BrokerClient client,
ConsumerInfo info,
Filter filter)
- Description copied from interface:
SubscriptionContainer
- Creates a subscription (which could be a previous subscription
reconecting) and adds it to this container
- Specified by:
makeSubscription
in interface SubscriptionContainer
- Returns:
createSubscription
protected Subscription createSubscription(Dispatcher dispatcher,
BrokerClient client,
ConsumerInfo info,
Filter filter)
Copyright © 2004-2009 Protique, Ltd.. All Rights Reserved.