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


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


Copyright © 2005-2011 FuseSource, Corp.. All Rights Reserved.