Save This Page
Home » activemq-parent-5.3.1-source-release » org.apache » activemq » broker » region » [javadoc | source]
org.apache.activemq.broker.region
public class: TopicRegion [javadoc | source]
java.lang.Object
   org.apache.activemq.broker.region.AbstractRegion
      org.apache.activemq.broker.region.TopicRegion

All Implemented Interfaces:
    Region

Direct Known Subclasses:
    ManagedTopicRegion

Field Summary
protected final  ConcurrentHashMap<SubscriptionKey, DurableTopicSubscription> durableSubscriptions     
Fields inherited from org.apache.activemq.broker.region.AbstractRegion:
destinations,  destinationMap,  subscriptions,  usageManager,  destinationFactory,  destinationStatistics,  broker,  autoCreateDestinations,  taskRunnerFactory,  destinationsMutex,  consumerChangeMutexMap,  started
Constructor:
 public TopicRegion(RegionBroker broker,
    DestinationStatistics destinationStatistics,
    SystemUsage memoryManager,
    TaskRunnerFactory taskRunnerFactory,
    DestinationFactory destinationFactory) 
Method from org.apache.activemq.broker.region.TopicRegion Summary:
addConsumer,   addSubscriptionsForDestination,   configureTopic,   createSubscription,   getInactiveDestinations,   isKeepDurableSubsActive,   removeConsumer,   removeSubscription,   setKeepDurableSubsActive,   toString
Methods from org.apache.activemq.broker.region.AbstractRegion:
acknowledge,   addConsumer,   addDestination,   addProducer,   addSubscriptionsForDestination,   createDestination,   createSubscription,   destroySubscription,   dispose,   gc,   getDestinationMap,   getDestinations,   getDurableDestinations,   getInactiveDestinations,   getSubscriptions,   isAutoCreateDestinations,   lookup,   messagePull,   processDispatchNotification,   processDispatchNotificationViaDestination,   removeConsumer,   removeDestination,   removeProducer,   removeSubscription,   send,   setAutoCreateDestinations,   start,   stop
Methods from java.lang.Object:
clone,   equals,   finalize,   getClass,   hashCode,   notify,   notifyAll,   toString,   wait,   wait,   wait
Method from org.apache.activemq.broker.region.TopicRegion Detail:
 public Subscription addConsumer(ConnectionContext context,
    ConsumerInfo info) throws Exception 
 protected List<Subscription> addSubscriptionsForDestination(ConnectionContext context,
    Destination dest) throws Exception 
 protected  void configureTopic(Topic topic,
    ActiveMQDestination destination) 
 protected Subscription createSubscription(ConnectionContext context,
    ConsumerInfo info) throws JMSException 
 protected Set<ActiveMQDestination> getInactiveDestinations() 
 public boolean isKeepDurableSubsActive() 
 public  void removeConsumer(ConnectionContext context,
    ConsumerInfo info) throws Exception 
 public  void removeSubscription(ConnectionContext context,
    RemoveSubscriptionInfo info) throws Exception 
 public  void setKeepDurableSubsActive(boolean keepDurableSubsActive) 
 public String toString()