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

All Implemented Interfaces:
    Region

Direct Known Subclasses:
    TempTopicRegion, AbstractTempRegion, TempQueueRegion, TopicRegion, ManagedTempTopicRegion, QueueRegion, ManagedTempQueueRegion, ManagedTopicRegion, ManagedQueueRegion

Field Summary
protected final  Map<ActiveMQDestination, Destination> destinations     
protected final  DestinationMap destinationMap     
protected final  Map<ConsumerId, Subscription> subscriptions     
protected final  SystemUsage usageManager     
protected final  DestinationFactory destinationFactory     
protected final  DestinationStatistics destinationStatistics     
protected final  RegionBroker broker     
protected  boolean autoCreateDestinations     
protected final  TaskRunnerFactory taskRunnerFactory     
protected final  Object destinationsMutex     
protected final  Map<ConsumerId, Object> consumerChangeMutexMap     
protected  boolean started     
Constructor:
 public AbstractRegion(RegionBroker broker,
    DestinationStatistics destinationStatistics,
    SystemUsage memoryManager,
    TaskRunnerFactory taskRunnerFactory,
    DestinationFactory destinationFactory) 
Method from org.apache.activemq.broker.region.AbstractRegion Summary:
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.AbstractRegion Detail:
 public  void acknowledge(ConsumerBrokerExchange consumerExchange,
    MessageAck ack) throws Exception 
 public Subscription addConsumer(ConnectionContext context,
    ConsumerInfo info) throws Exception 
 public Destination addDestination(ConnectionContext context,
    ActiveMQDestination destination) throws Exception 
 public  void addProducer(ConnectionContext context,
    ProducerInfo info) throws Exception 
 protected List<Subscription> addSubscriptionsForDestination(ConnectionContext context,
    Destination dest) throws Exception 
 protected Destination createDestination(ConnectionContext context,
    ActiveMQDestination destination) throws Exception 
 abstract protected Subscription createSubscription(ConnectionContext context,
    ConsumerInfo info) throws Exception
 protected  void destroySubscription(Subscription sub) 
 protected  void dispose(ConnectionContext context,
    Destination dest) throws Exception 
 public  void gc() 
 public Map<ActiveMQDestination, Destination> getDestinationMap() 
 public Set<Destination> getDestinations(ActiveMQDestination destination) 
    Provide an exact or wildcard lookup of destinations in the region
 public Set getDurableDestinations() 
    Get all the Destinations that are in storage
 protected Set<ActiveMQDestination> getInactiveDestinations() 
 public Map<ConsumerId, Subscription> getSubscriptions() 
 public boolean isAutoCreateDestinations() 
 protected Destination lookup(ConnectionContext context,
    ActiveMQDestination destination) throws Exception 
 public Response messagePull(ConnectionContext context,
    MessagePull pull) throws Exception 
 public  void processDispatchNotification(MessageDispatchNotification messageDispatchNotification) throws Exception 
 protected  void processDispatchNotificationViaDestination(MessageDispatchNotification messageDispatchNotification) throws Exception 
 public  void removeConsumer(ConnectionContext context,
    ConsumerInfo info) throws Exception 
 public  void removeDestination(ConnectionContext context,
    ActiveMQDestination destination,
    long timeout) throws Exception 
 public  void removeProducer(ConnectionContext context,
    ProducerInfo info) throws Exception 
    Removes a Producer.
 public  void removeSubscription(ConnectionContext context,
    RemoveSubscriptionInfo info) throws Exception 
 public  void send(ProducerBrokerExchange producerExchange,
    Message messageSend) throws Exception 
 public  void setAutoCreateDestinations(boolean autoCreateDestinations) 
 public final  void start() throws Exception 
 public  void stop() throws Exception