org.apache.activemq.broker.region
Class TempTopicRegion

java.lang.Object
  extended by org.apache.activemq.broker.region.AbstractRegion
      extended by org.apache.activemq.broker.region.AbstractTempRegion
          extended by org.apache.activemq.broker.region.TempTopicRegion
All Implemented Interfaces:
Region, Service
Direct Known Subclasses:
ManagedTempTopicRegion

public class TempTopicRegion
extends AbstractTempRegion


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
TempTopicRegion(RegionBroker broker, DestinationStatistics destinationStatistics, SystemUsage memoryManager, TaskRunnerFactory taskRunnerFactory, DestinationFactory destinationFactory)
           
 
Method Summary
protected  Subscription createSubscription(ConnectionContext context, ConsumerInfo info)
           
protected  Destination doCreateDestination(ConnectionContext context, ActiveMQDestination destination)
           
 void removeDestination(ConnectionContext context, ActiveMQDestination destination, long timeout)
          Used to destroy a destination.
 java.lang.String toString()
           
 
Methods inherited from class org.apache.activemq.broker.region.AbstractTempRegion
createDestination, dispose, stop
 
Methods inherited from class org.apache.activemq.broker.region.AbstractRegion
acknowledge, addConsumer, addDestination, addProducer, addSubscriptionsForDestination, destroySubscription, gc, getDestinationMap, getDestinations, getDurableDestinations, getInactiveDestinations, getSubscriptions, isAutoCreateDestinations, lookup, messagePull, processConsumerControl, processDispatchNotification, processDispatchNotificationViaDestination, removeConsumer, removeProducer, removeSubscription, send, setAutoCreateDestinations, start
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

TempTopicRegion

public TempTopicRegion(RegionBroker broker,
                       DestinationStatistics destinationStatistics,
                       SystemUsage memoryManager,
                       TaskRunnerFactory taskRunnerFactory,
                       DestinationFactory destinationFactory)
Method Detail

createSubscription

protected Subscription createSubscription(ConnectionContext context,
                                          ConsumerInfo info)
                                   throws javax.jms.JMSException
Specified by:
createSubscription in class AbstractRegion
Throws:
javax.jms.JMSException

toString

public java.lang.String toString()
Overrides:
toString in class java.lang.Object

removeDestination

public void removeDestination(ConnectionContext context,
                              ActiveMQDestination destination,
                              long timeout)
                       throws java.lang.Exception
Description copied from interface: Region
Used to destroy a destination. This should try to quiesce use of the destination up to the timeout allotted time before removing the destination. This will remove all persistent messages associated with the destination.

Specified by:
removeDestination in interface Region
Overrides:
removeDestination in class AbstractRegion
Parameters:
context - the environment the operation is being executed under.
destination - what is being removed from the broker.
timeout - the max amount of time to wait for the destination to quiesce
Throws:
java.lang.Exception - TODO

doCreateDestination

protected Destination doCreateDestination(ConnectionContext context,
                                          ActiveMQDestination destination)
                                   throws java.lang.Exception
Specified by:
doCreateDestination in class AbstractTempRegion
Throws:
java.lang.Exception


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