public class TopicRegion extends AbstractRegion
Modifier and Type | Field and Description |
---|---|
protected java.util.concurrent.ConcurrentHashMap<SubscriptionKey,DurableTopicSubscription> |
durableSubscriptions |
autoCreateDestinations, broker, consumerChangeMutexMap, destinationFactory, destinationMap, destinations, destinationsMutex, 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 java.util.List<Subscription> |
addSubscriptionsForDestination(ConnectionContext context,
Destination dest) |
protected void |
configureTopic(Topic topic,
ActiveMQDestination destination) |
protected Subscription |
createSubscription(ConnectionContext context,
ConsumerInfo info) |
boolean |
durableSubscriptionExists(SubscriptionKey key) |
protected java.util.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) |
java.lang.String |
toString() |
acknowledge, addDestination, addProducer, createDestination, destroySubscription, dispose, gc, getDestinationMap, getDestinations, getDurableDestinations, getSubscriptions, isAutoCreateDestinations, lookup, messagePull, processConsumerControl, processDispatchNotification, processDispatchNotificationViaDestination, removeDestination, removeProducer, send, setAutoCreateDestinations, start, stop
protected final java.util.concurrent.ConcurrentHashMap<SubscriptionKey,DurableTopicSubscription> durableSubscriptions
public TopicRegion(RegionBroker broker, DestinationStatistics destinationStatistics, SystemUsage memoryManager, TaskRunnerFactory taskRunnerFactory, DestinationFactory destinationFactory)
public Subscription addConsumer(ConnectionContext context, ConsumerInfo info) throws java.lang.Exception
Region
addConsumer
in interface Region
addConsumer
in class AbstractRegion
context
- the environment the operation is being executed under.java.lang.Exception
- TODOpublic void removeConsumer(ConnectionContext context, ConsumerInfo info) throws java.lang.Exception
Region
removeConsumer
in interface Region
removeConsumer
in class AbstractRegion
context
- the environment the operation is being executed under.java.lang.Exception
- TODOpublic void removeSubscription(ConnectionContext context, RemoveSubscriptionInfo info) throws java.lang.Exception
Region
removeSubscription
in interface Region
removeSubscription
in class AbstractRegion
context
- the environment the operation is being executed under.info
- TODOjava.lang.Exception
- TODOpublic java.lang.String toString()
toString
in class java.lang.Object
protected java.util.List<Subscription> addSubscriptionsForDestination(ConnectionContext context, Destination dest) throws java.lang.Exception
addSubscriptionsForDestination
in class AbstractRegion
java.lang.Exception
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 java.util.Set<ActiveMQDestination> getInactiveDestinations()
getInactiveDestinations
in class AbstractRegion
public boolean isKeepDurableSubsActive()
public void setKeepDurableSubsActive(boolean keepDurableSubsActive)
public boolean durableSubscriptionExists(SubscriptionKey key)
Copyright © 2005-2012. All Rights Reserved.