org.apache.activemq.broker.region
Class QueueRegion

java.lang.Object
  extended by org.apache.activemq.broker.region.AbstractRegion
      extended by 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


Copyright © 2009 Apache Software Foundation. All Rights Reserved.