org.apache.activemq.broker.jmx
Class ManagedRegionBroker

java.lang.Object
  extended by org.apache.activemq.broker.region.RegionBroker
      extended by org.apache.activemq.broker.jmx.ManagedRegionBroker
All Implemented Interfaces:
Broker, Region, Service

public class ManagedRegionBroker
extends RegionBroker


Field Summary
 
Fields inherited from class org.apache.activemq.broker.region.RegionBroker
connectionStates, destinationFactory, destinationStatistics
 
Constructor Summary
ManagedRegionBroker(BrokerService brokerService, javax.management.MBeanServer mbeanServer, javax.management.ObjectName brokerObjectName, TaskRunnerFactory taskRunnerFactory, UsageManager memoryManager, DestinationFactory destinationFactory, DestinationInterceptor destinationInterceptor)
           
 
Method Summary
protected  void addInactiveSubscription(SubscriptionKey key, SubscriptionInfo info)
           
 javax.management.openmbean.CompositeData[] browse(SubscriptionView view)
           
 javax.management.openmbean.TabularData browseAsTable(SubscriptionView view)
           
protected  void buildExistingSubscriptions()
           
protected  javax.management.ObjectName createObjectName(ActiveMQDestination destName)
           
protected  Region createQueueRegion(UsageManager memoryManager, TaskRunnerFactory taskRunnerFactory, DestinationFactory destinationFactory)
           
protected  Region createTempQueueRegion(UsageManager memoryManager, TaskRunnerFactory taskRunnerFactory, DestinationFactory destinationFactory)
           
protected  Region createTempTopicRegion(UsageManager memoryManager, TaskRunnerFactory taskRunnerFactory, DestinationFactory destinationFactory)
           
protected  Region createTopicRegion(UsageManager memoryManager, TaskRunnerFactory taskRunnerFactory, DestinationFactory destinationFactory)
           
protected  void doStop(ServiceStopper stopper)
           
 Broker getContextBroker()
           
protected  javax.management.ObjectName[] getDurableTopicSubscribers()
           
protected  javax.management.ObjectName[] getInactiveDurableTopicSubscribers()
           
protected  javax.management.ObjectName[] getQueues()
           
protected  javax.management.ObjectName[] getQueueSubscribers()
           
protected  java.util.List getSubscriberMessages(SubscriptionView view)
           
protected  javax.management.ObjectName[] getTemporaryQueues()
           
protected  javax.management.ObjectName[] getTemporaryQueueSubscribers()
           
protected  javax.management.ObjectName[] getTemporaryTopics()
           
protected  javax.management.ObjectName[] getTemporaryTopicSubscribers()
           
protected  javax.management.ObjectName[] getTopics()
           
protected  javax.management.ObjectName[] getTopicSubscribers()
           
 void register(ActiveMQDestination destName, Destination destination)
           
protected  void registerDestination(javax.management.ObjectName key, ActiveMQDestination dest, DestinationView view)
           
 javax.management.ObjectName registerSubscription(ConnectionContext context, Subscription sub)
           
protected  void registerSubscription(javax.management.ObjectName key, ConsumerInfo info, SubscriptionKey subscriptionKey, SubscriptionView view)
           
 void setContextBroker(Broker contextBroker)
           
 void start()
           
 void unregister(ActiveMQDestination destName)
           
protected  void unregisterDestination(javax.management.ObjectName key)
           
protected  void unregisterSubscription(javax.management.ObjectName key)
           
 void unregisterSubscription(Subscription sub)
           
 
Methods inherited from class org.apache.activemq.broker.region.RegionBroker
acknowledge, addBroker, addConnection, addConsumer, addDestination, addDestinationInfo, addProducer, addSession, beginTransaction, commitTransaction, createUnknownDestinationTypeException, forgetTransaction, gc, getAdaptor, getAdminConnectionContext, getBrokerId, getBrokerName, getClients, getConnectionStates, getDestinationInterceptor, getDestinationMap, getDestinationPolicy, getDestinations, getDestinations, getDestinationStatistics, getDurableDestinations, getPeerBrokerInfos, getPendingDurableSubscriberPolicy, getPreparedTransactions, getQueueRegion, getTempDataStore, getTempQueueRegion, getTempTopicRegion, getTopicRegion, isEqual, isFaultTolerantConfiguration, isKeepDurableSubsActive, isSlaveBroker, isStopped, messagePull, prepareTransaction, processDispatch, processDispatchNotification, removeBroker, removeConnection, removeConsumer, removeDestination, removeDestinationInfo, removeProducer, removeSession, removeSubscription, rollbackTransaction, send, setAdminConnectionContext, setBrokerId, setBrokerName, setKeepDurableSubsActive, setPendingDurableSubscriberPolicy, stop
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ManagedRegionBroker

public ManagedRegionBroker(BrokerService brokerService,
                           javax.management.MBeanServer mbeanServer,
                           javax.management.ObjectName brokerObjectName,
                           TaskRunnerFactory taskRunnerFactory,
                           UsageManager memoryManager,
                           DestinationFactory destinationFactory,
                           DestinationInterceptor destinationInterceptor)
                    throws java.io.IOException
Throws:
java.io.IOException
Method Detail

start

public void start()
           throws java.lang.Exception
Specified by:
start in interface Service
Overrides:
start in class RegionBroker
Throws:
java.lang.Exception

doStop

protected void doStop(ServiceStopper stopper)
Overrides:
doStop in class RegionBroker

createQueueRegion

protected Region createQueueRegion(UsageManager memoryManager,
                                   TaskRunnerFactory taskRunnerFactory,
                                   DestinationFactory destinationFactory)
Overrides:
createQueueRegion in class RegionBroker

createTempQueueRegion

protected Region createTempQueueRegion(UsageManager memoryManager,
                                       TaskRunnerFactory taskRunnerFactory,
                                       DestinationFactory destinationFactory)
Overrides:
createTempQueueRegion in class RegionBroker

createTempTopicRegion

protected Region createTempTopicRegion(UsageManager memoryManager,
                                       TaskRunnerFactory taskRunnerFactory,
                                       DestinationFactory destinationFactory)
Overrides:
createTempTopicRegion in class RegionBroker

createTopicRegion

protected Region createTopicRegion(UsageManager memoryManager,
                                   TaskRunnerFactory taskRunnerFactory,
                                   DestinationFactory destinationFactory)
Overrides:
createTopicRegion in class RegionBroker

register

public void register(ActiveMQDestination destName,
                     Destination destination)

unregister

public void unregister(ActiveMQDestination destName)

registerSubscription

public javax.management.ObjectName registerSubscription(ConnectionContext context,
                                                        Subscription sub)

unregisterSubscription

public void unregisterSubscription(Subscription sub)

registerDestination

protected void registerDestination(javax.management.ObjectName key,
                                   ActiveMQDestination dest,
                                   DestinationView view)
                            throws java.lang.Exception
Throws:
java.lang.Exception

unregisterDestination

protected void unregisterDestination(javax.management.ObjectName key)
                              throws java.lang.Exception
Throws:
java.lang.Exception

registerSubscription

protected void registerSubscription(javax.management.ObjectName key,
                                    ConsumerInfo info,
                                    SubscriptionKey subscriptionKey,
                                    SubscriptionView view)
                             throws java.lang.Exception
Throws:
java.lang.Exception

unregisterSubscription

protected void unregisterSubscription(javax.management.ObjectName key)
                               throws java.lang.Exception
Throws:
java.lang.Exception

buildExistingSubscriptions

protected void buildExistingSubscriptions()
                                   throws java.lang.Exception
Throws:
java.lang.Exception

addInactiveSubscription

protected void addInactiveSubscription(SubscriptionKey key,
                                       SubscriptionInfo info)

browse

public javax.management.openmbean.CompositeData[] browse(SubscriptionView view)
                                                  throws javax.management.openmbean.OpenDataException
Throws:
javax.management.openmbean.OpenDataException

browseAsTable

public javax.management.openmbean.TabularData browseAsTable(SubscriptionView view)
                                                     throws javax.management.openmbean.OpenDataException
Throws:
javax.management.openmbean.OpenDataException

getSubscriberMessages

protected java.util.List getSubscriberMessages(SubscriptionView view)

getTopics

protected javax.management.ObjectName[] getTopics()

getQueues

protected javax.management.ObjectName[] getQueues()

getTemporaryTopics

protected javax.management.ObjectName[] getTemporaryTopics()

getTemporaryQueues

protected javax.management.ObjectName[] getTemporaryQueues()

getTopicSubscribers

protected javax.management.ObjectName[] getTopicSubscribers()

getDurableTopicSubscribers

protected javax.management.ObjectName[] getDurableTopicSubscribers()

getQueueSubscribers

protected javax.management.ObjectName[] getQueueSubscribers()

getTemporaryTopicSubscribers

protected javax.management.ObjectName[] getTemporaryTopicSubscribers()

getTemporaryQueueSubscribers

protected javax.management.ObjectName[] getTemporaryQueueSubscribers()

getInactiveDurableTopicSubscribers

protected javax.management.ObjectName[] getInactiveDurableTopicSubscribers()

getContextBroker

public Broker getContextBroker()

setContextBroker

public void setContextBroker(Broker contextBroker)

createObjectName

protected javax.management.ObjectName createObjectName(ActiveMQDestination destName)
                                                throws javax.management.MalformedObjectNameException
Throws:
javax.management.MalformedObjectNameException


Copyright © 2011 Apache Software Foundation. All Rights Reserved.