org.apache.activemq.broker.region

Class QueueRegion

java.lang.Object

org.apache.activemq.broker.region.AbstractRegion

org.apache.activemq.broker.region.QueueRegion

All Implemented Interfaces:

Region, Service

Direct Known Subclasses:

ManagedQueueRegion

public class QueueRegion
extends AbstractRegion

Field Summary

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
QueueRegion(RegionBroker broker, DestinationStatistics destinationStatistics, SystemUsage memoryManager, TaskRunnerFactory taskRunnerFactory, DestinationFactory destinationFactory)

Method Summary

Methods

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()

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

QueueRegion

public QueueRegion(RegionBroker broker,
           DestinationStatistics destinationStatistics,
           SystemUsage memoryManager,
           TaskRunnerFactory taskRunnerFactory,
           DestinationFactory destinationFactory)

Method Detail

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

createSubscription

protected Subscription createSubscription(ConnectionContext context,
                              ConsumerInfo info)
                                   throws javax.jms.JMSException

Specified by:

createSubscription in class AbstractRegion

Throws:

javax.jms.JMSException

getInactiveDestinations

protected java.util.Set<ActiveMQDestination> getInactiveDestinations()

Overrides:

getInactiveDestinations in class AbstractRegion

Returns:

all Destinations that don't have active consumers

processDispatchNotification

public void processDispatchNotification(MessageDispatchNotification messageDispatchNotification)
                                 throws java.lang.Exception

Description copied from interface: Region

Process a notification of a dispatch - used by a Slave Broker

Specified by:

processDispatchNotification in interface Region

Overrides:

processDispatchNotification in class AbstractRegion

Throws:

java.lang.Exception - TODO