public class ManagedTempQueueRegion extends TempQueueRegion
autoCreateDestinations, broker, consumerChangeMutexMap, destinationFactory, destinationMap, destinations, destinationsLock, destinationStatistics, started, subscriptions, taskRunnerFactory, usageManager
Constructor and Description |
---|
ManagedTempQueueRegion(ManagedRegionBroker broker,
BrokerService brokerService,
DestinationStatistics destinationStatistics,
SystemUsage memoryManager,
TaskRunnerFactory taskRunnerFactory,
DestinationFactory destinationFactory) |
Modifier and Type | Method and Description |
---|---|
protected Destination |
createDestination(ConnectionContext context,
ActiveMQDestination destination) |
protected Subscription |
createSubscription(ConnectionContext context,
ConsumerInfo info) |
protected void |
destroySubscription(Subscription sub) |
void |
removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
Used to destroy a destination.
|
configureQueue, doCreateDestination, processDispatchNotification, toString
dispose, stop
acknowledge, addConsumer, addDestination, addProducer, addSubscriptionsForDestination, gc, getDestinationMap, getDestinations, getDurableDestinations, getInactiveDestinations, getSubscriptions, isAutoCreateDestinations, lookup, messagePull, processConsumerControl, processDispatchNotificationViaDestination, removeConsumer, removeProducer, removeSubscription, send, setAutoCreateDestinations, start
public ManagedTempQueueRegion(ManagedRegionBroker broker, BrokerService brokerService, DestinationStatistics destinationStatistics, SystemUsage memoryManager, TaskRunnerFactory taskRunnerFactory, DestinationFactory destinationFactory)
protected Subscription createSubscription(ConnectionContext context, ConsumerInfo info) throws javax.jms.JMSException
createSubscription
in class TempQueueRegion
javax.jms.JMSException
protected void destroySubscription(Subscription sub)
destroySubscription
in class AbstractRegion
protected Destination createDestination(ConnectionContext context, ActiveMQDestination destination) throws Exception
createDestination
in class AbstractTempRegion
Exception
public void removeDestination(ConnectionContext context, ActiveMQDestination destination, long timeout) throws Exception
Region
removeDestination
in interface Region
removeDestination
in class TempQueueRegion
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-2013 The Apache Software Foundation. All Rights Reserved.