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.2 $
SubscriptionContainerImpl
public SubscriptionContainerImpl(RedeliveryPolicy redeliveryPolicy,
DeadLetterPolicy deadLetterPolicy)
SubscriptionContainerImpl
public SubscriptionContainerImpl(Map subscriptions,
RedeliveryPolicy redeliveryPolicy,
DeadLetterPolicy deadLetterPolicy)
toString
public String toString()
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
- 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-2005 Protique, Ltd.. All Rights Reserved.