org.apache.activemq.broker.region
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 java.util.Set<ActiveMQDestination> |
getInactiveDestinations() |
void |
processDispatchNotification(MessageDispatchNotification messageDispatchNotification)
Process a notification of a dispatch - used by a Slave Broker
|
java.lang.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)
public java.lang.String toString()
toString
in class java.lang.Object
protected Subscription createSubscription(ConnectionContext context, ConsumerInfo info) throws javax.jms.JMSException
createSubscription
in class AbstractRegion
javax.jms.JMSException
protected java.util.Set<ActiveMQDestination> getInactiveDestinations()
getInactiveDestinations
in class AbstractRegion
public void processDispatchNotification(MessageDispatchNotification messageDispatchNotification) throws java.lang.Exception
Region
processDispatchNotification
in interface Region
processDispatchNotification
in class AbstractRegion
java.lang.Exception
- TODOCopyright © 2005-2014. All Rights Reserved.