Package org.apache.activemq.broker.jmx
Class ManagedTempTopicRegion
- java.lang.Object
-
- org.apache.activemq.broker.region.AbstractRegion
-
- org.apache.activemq.broker.region.AbstractTempRegion
-
- org.apache.activemq.broker.region.TempTopicRegion
-
- org.apache.activemq.broker.jmx.ManagedTempTopicRegion
-
public class ManagedTempTopicRegion extends TempTopicRegion
-
-
Field Summary
-
Fields inherited from class org.apache.activemq.broker.region.AbstractRegion
autoCreateDestinations, broker, consumerChangeMutexMap, destinationFactory, destinationMap, destinations, destinationsLock, destinationStatistics, regionStatistics, started, subscriptions, taskRunnerFactory, usageManager
-
-
Constructor Summary
Constructors Constructor Description ManagedTempTopicRegion(ManagedRegionBroker regionBroker, DestinationStatistics destinationStatistics, SystemUsage memoryManager, TaskRunnerFactory taskRunnerFactory, DestinationFactory destinationFactory)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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.TempTopicRegion
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, processDispatchNotification, processDispatchNotificationViaDestination, reapplyInterceptor, removeConsumer, removeProducer, removeSubscription, send, setAutoCreateDestinations, start, updateRegionDestCounts, validateMaxDestinations
-
-
-
-
Constructor Detail
-
ManagedTempTopicRegion
public ManagedTempTopicRegion(ManagedRegionBroker regionBroker, DestinationStatistics destinationStatistics, SystemUsage memoryManager, TaskRunnerFactory taskRunnerFactory, DestinationFactory destinationFactory)
-
-
Method Detail
-
createSubscription
protected Subscription createSubscription(ConnectionContext context, ConsumerInfo info) throws JMSException
- Overrides:
createSubscription
in classTempTopicRegion
- Throws:
JMSException
-
destroySubscription
protected void destroySubscription(Subscription sub)
- Overrides:
destroySubscription
in classAbstractRegion
-
createDestination
protected Destination createDestination(ConnectionContext context, ActiveMQDestination destination) throws Exception
- Overrides:
createDestination
in classAbstractTempRegion
- 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 interfaceRegion
- Overrides:
removeDestination
in classTempTopicRegion
- 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
-
-