org.apache.activemq.broker.jmx

Class ManagedTopicRegion

java.lang.Object

org.apache.activemq.broker.region.AbstractRegion

org.apache.activemq.broker.region.TopicRegion

org.apache.activemq.broker.jmx.ManagedTopicRegion

All Implemented Interfaces:

Region, Service

public class ManagedTopicRegion
extends TopicRegion

Field Summary

Fields inherited from class org.apache.activemq.broker.region.TopicRegion

durableSubscriptions

Fields inherited from class org.apache.activemq.broker.region.AbstractRegion

autoCreateDestinations, broker, consumerChangeMutexMap, destinationFactory, destinationMap, destinations, destinationsLock, destinationStatistics, started, subscriptions, taskRunnerFactory, usageManager

Constructor Summary

Constructors

Constructor and Description
ManagedTopicRegion(ManagedRegionBroker broker, DestinationStatistics destinationStatistics, SystemUsage memoryManager, TaskRunnerFactory taskRunnerFactory, DestinationFactory destinationFactory)

Method Summary

Methods

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.

Methods inherited from class org.apache.activemq.broker.region.TopicRegion

addConsumer, addSubscriptionsForDestination, configureTopic, createInactiveConsumerInfo, doCleanup, durableSubscriptionExists, getDurableSubscription, getInactiveDestinations, isKeepDurableSubsActive, lookupSubscription, lookupSubscriptions, removeConsumer, removeSubscription, setKeepDurableSubsActive, stop, toString

Methods inherited from class org.apache.activemq.broker.region.AbstractRegion

acknowledge, addDestination, addProducer, dispose, gc, getDestinationMap, getDestinations, getDurableDestinations, getSubscriptions, isAutoCreateDestinations, lookup, messagePull, processConsumerControl, processDispatchNotification, processDispatchNotificationViaDestination, reapplyInterceptor, removeProducer, send, setAutoCreateDestinations, start

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ManagedTopicRegion

public ManagedTopicRegion(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 TopicRegion

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 AbstractRegion

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 AbstractRegion

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