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

Version:

$Revision: 1.9 $

Field Summary

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

autoCreateDestinations, broker, consumerChangeMutexMap, destinationFactory, destinationMap, destinations, destinationsMutex, destinationStatistics, started, subscriptions, taskRunnerFactory, usageManager

Constructor Summary

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

Method Summary

protected Subscription	createSubscription(ConnectionContext context, ConsumerInfo info)
protected Set<ActiveMQDestination>	getInactiveDestinations()
String	toString()

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

acknowledge, addConsumer, addDestination, addProducer, addSubscriptionsForDestination, createDestination, destroySubscription, dispose, gc, getDestinationMap, getDestinations, getDurableDestinations, isAutoCreateDestinations, lookup, messagePull, processDispatchNotification, 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 String toString()

Overrides:

toString in class Object

createSubscription

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

Specified by:

createSubscription in class AbstractRegion

Throws:

JMSException

getInactiveDestinations

protected Set<ActiveMQDestination> getInactiveDestinations()

Overrides:

getInactiveDestinations in class AbstractRegion

Returns:

all Destinations that don't have active consumers