public class TopicRegion extends AbstractRegion
Modifier and Type | Field and Description |
---|---|
protected ConcurrentMap<SubscriptionKey,DurableTopicSubscription> |
durableSubscriptions |
autoCreateDestinations, broker, consumerChangeMutexMap, destinationFactory, destinationMap, destinations, destinationsLock, destinationStatistics, regionStatistics, started, subscriptions, taskRunnerFactory, usageManager
Constructor and Description |
---|
TopicRegion(RegionBroker broker,
DestinationStatistics destinationStatistics,
SystemUsage memoryManager,
TaskRunnerFactory taskRunnerFactory,
DestinationFactory destinationFactory) |
acknowledge, addDestination, addProducer, createDestination, destroySubscription, dispose, gc, getDestinationMap, getDestinations, getDurableDestinations, getSubscriptions, isAutoCreateDestinations, lookup, messagePull, processConsumerControl, processDispatchNotification, processDispatchNotificationViaDestination, reapplyInterceptor, removeDestination, removeProducer, send, setAutoCreateDestinations, start, updateRegionDestCounts, validateMaxDestinations
protected final ConcurrentMap<SubscriptionKey,DurableTopicSubscription> durableSubscriptions
public TopicRegion(RegionBroker broker, DestinationStatistics destinationStatistics, SystemUsage memoryManager, TaskRunnerFactory taskRunnerFactory, DestinationFactory destinationFactory)
public void stop() throws Exception
stop
in interface Service
stop
in class AbstractRegion
Exception
public void doCleanup()
public Subscription addConsumer(ConnectionContext context, ConsumerInfo info) throws Exception
Region
addConsumer
in interface Region
addConsumer
in class AbstractRegion
context
- the environment the operation is being executed under.Exception
- TODOpublic void removeConsumer(ConnectionContext context, ConsumerInfo info) throws Exception
Region
removeConsumer
in interface Region
removeConsumer
in class AbstractRegion
context
- the environment the operation is being executed under.Exception
- TODOpublic void removeSubscription(ConnectionContext context, RemoveSubscriptionInfo info) throws Exception
Region
removeSubscription
in interface Region
removeSubscription
in class AbstractRegion
context
- the environment the operation is being executed under.info
- TODOException
- TODOprotected List<Subscription> addSubscriptionsForDestination(ConnectionContext context, Destination dest) throws Exception
addSubscriptionsForDestination
in class AbstractRegion
Exception
public ConsumerInfo createInactiveConsumerInfo(SubscriptionInfo info)
protected void configureTopic(Topic topic, ActiveMQDestination destination)
protected Subscription createSubscription(ConnectionContext context, ConsumerInfo info) throws javax.jms.JMSException
createSubscription
in class AbstractRegion
javax.jms.JMSException
protected Set<ActiveMQDestination> getInactiveDestinations()
getInactiveDestinations
in class AbstractRegion
public DurableTopicSubscription lookupSubscription(String subscriptionName, String clientId)
public List<DurableTopicSubscription> lookupSubscriptions(String clientId)
public boolean isKeepDurableSubsActive()
public void setKeepDurableSubsActive(boolean keepDurableSubsActive)
public boolean durableSubscriptionExists(SubscriptionKey key)
public DurableTopicSubscription getDurableSubscription(SubscriptionKey key)
public Map<SubscriptionKey,DurableTopicSubscription> getDurableSubscriptions()
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.