public class ManagedTempTopicRegion extends TempTopicRegion
autoCreateDestinations, broker, consumerChangeMutexMap, destinationFactory, destinationMap, destinations, destinationsLock, destinationStatistics, started, subscriptions, taskRunnerFactory, usageManager| Constructor and Description |
|---|
ManagedTempTopicRegion(ManagedRegionBroker regionBroker,
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.
|
toStringdispose, stopacknowledge, addConsumer, addDestination, addProducer, addSubscriptionsForDestination, gc, getDestinationMap, getDestinations, getDurableDestinations, getInactiveDestinations, getSubscriptions, isAutoCreateDestinations, lookup, messagePull, processConsumerControl, processDispatchNotification, processDispatchNotificationViaDestination, reapplyInterceptor, removeConsumer, removeProducer, removeSubscription, send, setAutoCreateDestinations, startpublic ManagedTempTopicRegion(ManagedRegionBroker regionBroker, DestinationStatistics destinationStatistics, SystemUsage memoryManager, TaskRunnerFactory taskRunnerFactory, DestinationFactory destinationFactory)
protected Subscription createSubscription(ConnectionContext context, ConsumerInfo info) throws JMSException
createSubscription in class TempTopicRegionJMSExceptionprotected void destroySubscription(Subscription sub)
destroySubscription in class AbstractRegionprotected Destination createDestination(ConnectionContext context, ActiveMQDestination destination) throws Exception
createDestination in class AbstractTempRegionExceptionpublic void removeDestination(ConnectionContext context, ActiveMQDestination destination, long timeout) throws Exception
RegionremoveDestination in interface RegionremoveDestination in class TempTopicRegioncontext - 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–2015 FuseSource, Corp.. All rights reserved.