org.apache.activemq.broker.jmx
Class ManagedRegionBroker

java.lang.Object
  org.apache.activemq.broker.EmptyBroker
      org.apache.activemq.broker.region.RegionBroker
          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

Constructor Summary

ManagedRegionBroker(BrokerService brokerService, MBeanServer mbeanServer, 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,
                           MBeanServer mbeanServer,
                           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