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, memoryManager, subscriptions, taskRunnerFactory

Constructor Summary

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

Method Summary

protected Subscription	createSubscription(ConnectionContext context, ConsumerInfo info)
protected java.util.Set	getInactiveDestinations()
java.lang.String	toString()

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

acknowledge, addConsumer, addDestination, createDestination, destroySubscription, gc, getDestinationMap, getDestinations, getDurableDestinations, isAutoCreateDestinations, lookup, messagePull, processDispatchNotification, removeConsumer, removeDestination, 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,
                   UsageManager 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.InvalidSelectorException

Specified by:

createSubscription in class AbstractRegion

Throws:

javax.jms.InvalidSelectorException

getInactiveDestinations

protected java.util.Set getInactiveDestinations()

Overrides:

getInactiveDestinations in class AbstractRegion

Returns:

all Destinations that don't have active consumers