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 java.lang.Object
- implements SubscriptionContainer
A default RAM only implementation of the SubscriptionContainer
- Version:
- $Revision: 1.1.1.1 $
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
SubscriptionContainerImpl
public SubscriptionContainerImpl(RedeliveryPolicy redeliveryPolicy,
DeadLetterPolicy deadLetterPolicy)
SubscriptionContainerImpl
public SubscriptionContainerImpl(java.util.Map subscriptions,
RedeliveryPolicy redeliveryPolicy,
DeadLetterPolicy deadLetterPolicy)
toString
public java.lang.String toString()
getRedeliveryPolicy
public RedeliveryPolicy getRedeliveryPolicy()
getDeadLetterPolicy
public DeadLetterPolicy getDeadLetterPolicy()
getSubscription
public Subscription getSubscription(java.lang.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(java.lang.String consumerId)
- Specified by:
removeSubscription
in interface SubscriptionContainer
getSubscriptions
public java.util.Set getSubscriptions(ActiveMQDestination destination)
- Specified by:
getSubscriptions
in interface SubscriptionContainer
- Parameters:
destination
-
- Returns:
- a collection of subscriptions for the given destination
subscriptionIterator
public java.util.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.