public class TopicRegion extends AbstractRegion
Modifier and Type | Field and Description |
---|---|
protected ConcurrentHashMap<SubscriptionKey,DurableTopicSubscription> |
durableSubscriptions |
autoCreateDestinations, broker, consumerChangeMutexMap, destinationFactory, destinationMap, destinations, destinationsLock, destinationStatistics, started, subscriptions, taskRunnerFactory, usageManager
Constructor and Description |
---|
TopicRegion(RegionBroker broker,
DestinationStatistics destinationStatistics,
SystemUsage memoryManager,
TaskRunnerFactory taskRunnerFactory,
DestinationFactory destinationFactory) |
Modifier and Type | Method and Description |
---|---|
Subscription |
addConsumer(ConnectionContext context,
ConsumerInfo info)
Adds a consumer.
|
protected List<Subscription> |
addSubscriptionsForDestination(ConnectionContext context,
Destination dest) |
protected void |
configureTopic(Topic topic,
ActiveMQDestination destination) |
ConsumerInfo |
createInactiveConsumerInfo(SubscriptionInfo info) |
protected Subscription |
createSubscription(ConnectionContext context,
ConsumerInfo info) |
void |
doCleanup() |
boolean |
durableSubscriptionExists(SubscriptionKey key) |
protected Set<ActiveMQDestination> |
getInactiveDestinations() |
boolean |
isKeepDurableSubsActive() |
void |
removeConsumer(ConnectionContext context,
ConsumerInfo info)
Removes a consumer.
|
void |
removeSubscription(ConnectionContext context,
RemoveSubscriptionInfo info)
Deletes a durable subscription.
|
void |
setKeepDurableSubsActive(boolean keepDurableSubsActive) |
void |
stop() |
String |
toString() |
acknowledge, addDestination, addProducer, createDestination, destroySubscription, dispose, gc, getDestinationMap, getDestinations, getDurableDestinations, getSubscriptions, isAutoCreateDestinations, lookup, messagePull, processConsumerControl, processDispatchNotification, processDispatchNotificationViaDestination, removeDestination, removeProducer, send, setAutoCreateDestinations, start
protected final ConcurrentHashMap<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 boolean isKeepDurableSubsActive()
public void setKeepDurableSubsActive(boolean keepDurableSubsActive)
public boolean durableSubscriptionExists(SubscriptionKey key)
Copyright © 2005–2014. All rights reserved.