org.codehaus.activemq.service.impl
Class SubscriptionContainerImpl
java.lang.Object
org.codehaus.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.6 $
SubscriptionContainerImpl
public SubscriptionContainerImpl(RedeliveryPolicy redeliveryPolicy)
SubscriptionContainerImpl
public SubscriptionContainerImpl(Map subscriptions,
RedeliveryPolicy redeliveryPolicy)
toString
public String toString()
getRedeliveryPolicy
public RedeliveryPolicy getRedeliveryPolicy()
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
- Parameters:
consumerId
-
- 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
- Parameters:
destination
-
- 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
- Parameters:
dispatcher
- client
- info
- filter
-
- Returns:
createSubscription
protected Subscription createSubscription(Dispatcher dispatcher,
BrokerClient client,
ConsumerInfo info,
Filter filter)
Copyright © 2004 Protique, Ltd.. All Rights Reserved.