org.apache.activemq.broker.jmx
Class ManagedRegionBroker

java.lang.Object
  extended by org.apache.activemq.broker.EmptyBroker
      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
brokerService, connectionStates, destinationFactory, destinationStatistics, ORIGINAL_EXPIRATION
 
Constructor Summary
ManagedRegionBroker(BrokerService brokerService, ManagementContext context, ObjectName brokerObjectName, TaskRunnerFactory taskRunnerFactory, SystemUsage memoryManager, DestinationFactory destinationFactory, DestinationInterceptor destinationInterceptor)
           
 
Method Summary
protected  void addInactiveSubscription(SubscriptionKey key, SubscriptionInfo info)
           
 CompositeData[] browse(SubscriptionView view)
           
 TabularData browseAsTable(SubscriptionView view)
           
protected  void buildExistingSubscriptions()
           
protected  ObjectName createObjectName(ActiveMQDestination destName)
           
protected  Region createQueueRegion(SystemUsage memoryManager, TaskRunnerFactory taskRunnerFactory, DestinationFactory destinationFactory)
           
protected  Region createTempQueueRegion(SystemUsage memoryManager, TaskRunnerFactory taskRunnerFactory, DestinationFactory destinationFactory)
           
protected  Region createTempTopicRegion(SystemUsage memoryManager, TaskRunnerFactory taskRunnerFactory, DestinationFactory destinationFactory)
           
protected  Region createTopicRegion(SystemUsage memoryManager, TaskRunnerFactory taskRunnerFactory, DestinationFactory destinationFactory)
           
protected  void doStop(ServiceStopper stopper)
           
 Broker getContextBroker()
           
protected  ObjectName[] getDurableTopicSubscribers()
           
protected  ObjectName[] getInactiveDurableTopicSubscribers()
           
protected  ObjectName[] getQueues()
           
protected  ObjectName[] getQueueSubscribers()
           
protected  List<Message> getSubscriberMessages(SubscriptionView view)
           
static String getSubscriptionObjectName(Subscription sub, String connectionClientId, ObjectName brokerJmxObjectName)
           
protected  ObjectName[] getTemporaryQueues()
           
protected  ObjectName[] getTemporaryQueueSubscribers()
           
protected  ObjectName[] getTemporaryTopics()
           
protected  ObjectName[] getTemporaryTopicSubscribers()
           
protected  ObjectName[] getTopics()
           
protected  ObjectName[] getTopicSubscribers()
           
 void register(ActiveMQDestination destName, Destination destination)
           
protected  void registerDestination(ObjectName key, ActiveMQDestination dest, DestinationView view)
           
 ObjectName registerSubscription(ConnectionContext context, Subscription sub)
           
protected  void registerSubscription(ObjectName key, ConsumerInfo info, SubscriptionKey subscriptionKey, SubscriptionView view)
           
 void setContextBroker(Broker contextBroker)
           
 void start()
           
 void unregister(ActiveMQDestination destName)
           
protected  void unregisterDestination(ObjectName key)
           
protected  void unregisterSubscription(ObjectName key)
           
 void unregisterSubscription(Subscription sub)
           
 
Methods inherited from class org.apache.activemq.broker.region.RegionBroker
acknowledge, addBroker, addConnection, addConsumer, addDestination, addDestinationInfo, addProducer, beginTransaction, brokerServiceStarted, commitTransaction, createUnknownDestinationTypeException, forgetTransaction, gc, getAdaptor, getAdminConnectionContext, getBrokerId, getBrokerName, getBrokerSequenceId, getBrokerService, getClients, getConnectionStates, getDestinationInterceptor, getDestinationMap, getDestinationPolicy, getDestinations, getDestinations, getDestinationStatistics, getDurableDestinations, getPeerBrokerInfos, getPreparedTransactions, getQueueRegion, getRoot, getTempDataStore, getTempQueueRegion, getTempTopicRegion, getTopicRegion, getVmConnectorURI, isEqual, isExpired, isKeepDurableSubsActive, isSlaveBroker, isStopped, messageExpired, messagePull, postProcessDispatch, prepareTransaction, preProcessDispatch, processDispatchNotification, removeBroker, removeConnection, removeConsumer, removeDestination, removeDestinationInfo, removeProducer, removeSubscription, rollbackTransaction, send, sendToDeadLetterQueue, setAdminConnectionContext, setBrokerId, setBrokerName, setKeepDurableSubsActive, stop
 
Methods inherited from class org.apache.activemq.broker.EmptyBroker
addSession, fastProducer, isFaultTolerantConfiguration, isFull, messageConsumed, messageDelivered, messageDiscarded, nowMasterBroker, removeSession, slowConsumer
 
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,
                           ManagementContext context,
                           ObjectName brokerObjectName,
                           TaskRunnerFactory taskRunnerFactory,
                           SystemUsage memoryManager,
                           DestinationFactory destinationFactory,
                           DestinationInterceptor destinationInterceptor)
                    throws IOException
Throws:
IOException
Method Detail

start

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

doStop

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

createQueueRegion

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

createTempQueueRegion

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

createTempTopicRegion

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

createTopicRegion

protected Region createTopicRegion(SystemUsage 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 ObjectName registerSubscription(ConnectionContext context,
                                       Subscription sub)

getSubscriptionObjectName

public static String getSubscriptionObjectName(Subscription sub,
                                               String connectionClientId,
                                               ObjectName brokerJmxObjectName)

unregisterSubscription

public void unregisterSubscription(Subscription sub)

registerDestination

protected void registerDestination(ObjectName key,
                                   ActiveMQDestination dest,
                                   DestinationView view)
                            throws Exception
Throws:
Exception

unregisterDestination

protected void unregisterDestination(ObjectName key)
                              throws Exception
Throws:
Exception

registerSubscription

protected void registerSubscription(ObjectName key,
                                    ConsumerInfo info,
                                    SubscriptionKey subscriptionKey,
                                    SubscriptionView view)
                             throws Exception
Throws:
Exception

unregisterSubscription

protected void unregisterSubscription(ObjectName key)
                               throws Exception
Throws:
Exception

buildExistingSubscriptions

protected void buildExistingSubscriptions()
                                   throws Exception
Throws:
Exception

addInactiveSubscription

protected void addInactiveSubscription(SubscriptionKey key,
                                       SubscriptionInfo info)

browse

public CompositeData[] browse(SubscriptionView view)
                       throws OpenDataException
Throws:
OpenDataException

browseAsTable

public TabularData browseAsTable(SubscriptionView view)
                          throws OpenDataException
Throws:
OpenDataException

getSubscriberMessages

protected List<Message> getSubscriberMessages(SubscriptionView view)

getTopics

protected ObjectName[] getTopics()

getQueues

protected ObjectName[] getQueues()

getTemporaryTopics

protected ObjectName[] getTemporaryTopics()

getTemporaryQueues

protected ObjectName[] getTemporaryQueues()

getTopicSubscribers

protected ObjectName[] getTopicSubscribers()

getDurableTopicSubscribers

protected ObjectName[] getDurableTopicSubscribers()

getQueueSubscribers

protected ObjectName[] getQueueSubscribers()

getTemporaryTopicSubscribers

protected ObjectName[] getTemporaryTopicSubscribers()

getTemporaryQueueSubscribers

protected ObjectName[] getTemporaryQueueSubscribers()

getInactiveDurableTopicSubscribers

protected ObjectName[] getInactiveDurableTopicSubscribers()

getContextBroker

public Broker getContextBroker()

setContextBroker

public void setContextBroker(Broker contextBroker)

createObjectName

protected ObjectName createObjectName(ActiveMQDestination destName)
                               throws MalformedObjectNameException
Throws:
MalformedObjectNameException


Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.