public class TempTopicRegion extends AbstractTempRegion
autoCreateDestinations, broker, consumerChangeMutexMap, destinationFactory, destinationMap, destinations, destinationsLock, destinationStatistics, regionStatistics, started, subscriptions, taskRunnerFactory, usageManager
Constructor and Description |
---|
TempTopicRegion(RegionBroker broker,
DestinationStatistics destinationStatistics,
SystemUsage memoryManager,
TaskRunnerFactory taskRunnerFactory,
DestinationFactory destinationFactory) |
Modifier and Type | Method and Description |
---|---|
protected Subscription |
createSubscription(ConnectionContext context,
ConsumerInfo info) |
void |
removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
Used to destroy a destination.
|
String |
toString() |
createDestination, dispose, stop
acknowledge, addConsumer, addDestination, addProducer, addSubscriptionsForDestination, destroySubscription, gc, getDestinationMap, getDestinations, getDurableDestinations, getInactiveDestinations, getSubscriptions, isAutoCreateDestinations, lookup, messagePull, processConsumerControl, processDispatchNotification, processDispatchNotificationViaDestination, reapplyInterceptor, removeConsumer, removeProducer, removeSubscription, send, setAutoCreateDestinations, start, updateRegionDestCounts, validateMaxDestinations
public TempTopicRegion(RegionBroker broker, DestinationStatistics destinationStatistics, SystemUsage memoryManager, TaskRunnerFactory taskRunnerFactory, DestinationFactory destinationFactory)
protected Subscription createSubscription(ConnectionContext context, ConsumerInfo info) throws javax.jms.JMSException
createSubscription
in class AbstractRegion
javax.jms.JMSException
public void removeDestination(ConnectionContext context, ActiveMQDestination destination, long timeout) throws Exception
Region
removeDestination
in interface Region
removeDestination
in class AbstractRegion
context
- the environment the operation is being executed under.destination
- what is being removed from the broker.timeout
- the max amount of time to wait for the destination to quiesceException
- TODOCopyright © 2005–2019 The Apache Software Foundation. All rights reserved.