org.apache.activemq.broker.jmx
Class ManagedTempQueueRegion

java.lang.Object
  extended by org.apache.activemq.broker.region.AbstractRegion
      extended by org.apache.activemq.broker.region.AbstractTempRegion
          extended by org.apache.activemq.broker.region.TempQueueRegion
              extended by org.apache.activemq.broker.jmx.ManagedTempQueueRegion
All Implemented Interfaces:
Region, Service

public class ManagedTempQueueRegion
extends TempQueueRegion


Field Summary
 
Fields inherited from class org.apache.activemq.broker.region.AbstractRegion
autoCreateDestinations, broker, consumerChangeMutexMap, destinationFactory, destinationMap, destinations, destinationsLock, destinationStatistics, started, subscriptions, taskRunnerFactory, usageManager
 
Constructor Summary
ManagedTempQueueRegion(ManagedRegionBroker broker, DestinationStatistics destinationStatistics, SystemUsage memoryManager, TaskRunnerFactory taskRunnerFactory, DestinationFactory destinationFactory)
           
 
Method Summary
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.
 
Methods inherited from class org.apache.activemq.broker.region.TempQueueRegion
processDispatchNotification, toString
 
Methods inherited from class org.apache.activemq.broker.region.AbstractTempRegion
dispose, stop
 
Methods inherited from class org.apache.activemq.broker.region.AbstractRegion
acknowledge, addConsumer, addDestination, addProducer, addSubscriptionsForDestination, gc, getDestinationMap, getDestinations, getDurableDestinations, getInactiveDestinations, getSubscriptions, isAutoCreateDestinations, lookup, messagePull, processConsumerControl, processDispatchNotificationViaDestination, removeConsumer, removeProducer, removeSubscription, send, setAutoCreateDestinations, start
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

ManagedTempQueueRegion

public ManagedTempQueueRegion(ManagedRegionBroker broker,
                              DestinationStatistics destinationStatistics,
                              SystemUsage memoryManager,
                              TaskRunnerFactory taskRunnerFactory,
                              DestinationFactory destinationFactory)
Method Detail

createSubscription

protected Subscription createSubscription(ConnectionContext context,
                                          ConsumerInfo info)
                                   throws JMSException
Overrides:
createSubscription in class TempQueueRegion
Throws:
JMSException

destroySubscription

protected void destroySubscription(Subscription sub)
Overrides:
destroySubscription in class AbstractRegion

createDestination

protected Destination createDestination(ConnectionContext context,
                                        ActiveMQDestination destination)
                                 throws Exception
Overrides:
createDestination in class AbstractTempRegion
Throws:
Exception

removeDestination

public void removeDestination(ConnectionContext context,
                              ActiveMQDestination destination,
                              long timeout)
                       throws Exception
Description copied from interface: Region
Used to destroy a destination. This should try to quiesce use of the destination up to the timeout allotted time before removing the destination. This will remove all persistent messages associated with the destination.

Specified by:
removeDestination in interface Region
Overrides:
removeDestination in class TempQueueRegion
Parameters:
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 quiesce
Throws:
Exception - TODO


Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.