public class QueueRegion extends AbstractRegion
autoCreateDestinations, broker, consumerChangeMutexMap, destinationFactory, destinationMap, destinations, destinationsLock, destinationStatistics, started, subscriptions, taskRunnerFactory, usageManager
Constructor and Description |
---|
QueueRegion(RegionBroker broker,
DestinationStatistics destinationStatistics,
SystemUsage memoryManager,
TaskRunnerFactory taskRunnerFactory,
DestinationFactory destinationFactory) |
Modifier and Type | Method and Description |
---|---|
protected Subscription |
createSubscription(ConnectionContext context,
ConsumerInfo info) |
protected Set<ActiveMQDestination> |
getInactiveDestinations() |
void |
processDispatchNotification(MessageDispatchNotification messageDispatchNotification)
Process a notification of a dispatch - used by a Slave Broker
|
String |
toString() |
acknowledge, addConsumer, addDestination, addProducer, addSubscriptionsForDestination, createDestination, destroySubscription, dispose, gc, getDestinationMap, getDestinations, getDurableDestinations, getSubscriptions, isAutoCreateDestinations, lookup, messagePull, processConsumerControl, processDispatchNotificationViaDestination, removeConsumer, removeDestination, removeProducer, removeSubscription, send, setAutoCreateDestinations, start, stop
public QueueRegion(RegionBroker broker, DestinationStatistics destinationStatistics, SystemUsage memoryManager, TaskRunnerFactory taskRunnerFactory, DestinationFactory destinationFactory)
protected Subscription createSubscription(ConnectionContext context, ConsumerInfo info) throws javax.jms.JMSException
createSubscription
in class AbstractRegion
javax.jms.JMSException
protected Set<ActiveMQDestination> getInactiveDestinations()
getInactiveDestinations
in class AbstractRegion
public void processDispatchNotification(MessageDispatchNotification messageDispatchNotification) throws Exception
Region
processDispatchNotification
in interface Region
processDispatchNotification
in class AbstractRegion
Exception
- TODOCopyright © 2005-2012 Apache Software Foundation. All Rights Reserved.