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, ORIGINAL_EXPIRATION

Constructor Summary

Constructors

Constructor and Description
ManagedRegionBroker(BrokerService brokerService, ManagementContext context, javax.management.ObjectName brokerObjectName, TaskRunnerFactory taskRunnerFactory, SystemUsage memoryManager, DestinationFactory destinationFactory, DestinationInterceptor destinationInterceptor, Scheduler scheduler, java.util.concurrent.ThreadPoolExecutor executor)

Method Summary

Methods

Modifier and Type	Method and Description
Subscription	addConsumer(ConnectionContext context, ConsumerInfo info) Adds a consumer.
protected void	addInactiveSubscription(SubscriptionKey key, SubscriptionInfo info, Subscription subscription)
void	addProducer(ConnectionContext context, ProducerInfo info) Adds a producer.
javax.management.openmbean.CompositeData[]	browse(SubscriptionView view)
javax.management.openmbean.TabularData	browseAsTable(SubscriptionView view)
protected void	buildExistingSubscriptions()
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 javax.management.ObjectName[]	getDurableTopicSubscribers()
protected javax.management.ObjectName[]	getDynamicDestinationProducers()
protected javax.management.ObjectName[]	getInactiveDurableTopicSubscribers()
protected javax.management.ObjectName[]	getQueueProducers()
protected javax.management.ObjectName[]	getQueues()
protected javax.management.ObjectName[]	getQueueSubscribers()
java.util.Map<javax.management.ObjectName,DestinationView>	getQueueViews()
Subscription	getSubscriber(javax.management.ObjectName key)
protected java.util.List<Message>	getSubscriberMessages(SubscriptionView view)
javax.management.ObjectName	getSubscriberObjectName(Subscription key)
protected javax.management.ObjectName[]	getTemporaryQueueProducers()
protected javax.management.ObjectName[]	getTemporaryQueues()
protected javax.management.ObjectName[]	getTemporaryQueueSubscribers()
protected javax.management.ObjectName[]	getTemporaryTopicProducers()
protected javax.management.ObjectName[]	getTemporaryTopics()
protected javax.management.ObjectName[]	getTemporaryTopicSubscribers()
protected javax.management.ObjectName[]	getTopicProducers()
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)
protected void	registerProducer(javax.management.ObjectName key, ActiveMQDestination dest, ProducerView view)
void	registerRecoveredTransactionMBean(XATransaction transaction)
javax.management.ObjectName	registerSlowConsumerStrategy(AbortSlowConsumerStrategy strategy)
javax.management.ObjectName	registerSubscription(ConnectionContext context, Subscription sub)
protected void	registerSubscription(javax.management.ObjectName key, ConsumerInfo info, SubscriptionKey subscriptionKey, SubscriptionView view)
void	removeConsumer(ConnectionContext context, ConsumerInfo info) Removes a consumer.
void	removeProducer(ConnectionContext context, ProducerInfo info) Removes a producer.
void	send(ProducerBrokerExchange exchange, Message message) Send a message to the broker to using the specified destination.
void	setContextBroker(Broker contextBroker)
void	start()
void	unregister(ActiveMQDestination destName)
void	unregister(XATransaction transaction)
protected void	unregisterDestination(javax.management.ObjectName key)
protected void	unregisterProducer(javax.management.ObjectName key)
protected void	unregisterSubscription(javax.management.ObjectName key, boolean addToInactive)
void	unregisterSubscription(Subscription sub)

Methods inherited from class org.apache.activemq.broker.region.RegionBroker

acknowledge, addBroker, addBrokerInClusterUpdate, addConnection, addDestination, addDestinationInfo, beginTransaction, brokerServiceStarted, commitTransaction, createUnknownDestinationTypeException, forgetTransaction, gc, getAdaptor, getAdminConnectionContext, getBrokerId, getBrokerName, getBrokerSequenceId, getBrokerService, getClients, getConnectionStates, getDestinationInterceptor, getDestinationMap, getDestinationPolicy, getDestinations, getDestinations, getDestinationStatistics, getDurableDestinations, getExecutor, getPeerBrokerInfos, getPreparedTransactions, getQueueRegion, getRegion, getRoot, getScheduler, getTempDataStore, getTempQueueRegion, getTempTopicRegion, getTopicRegion, getVmConnectorURI, isAllowTempAutoCreationOnSend, isEqual, isExpired, isKeepDurableSubsActive, isStopped, messageExpired, messagePull, postProcessDispatch, prepareTransaction, preProcessDispatch, processConsumerControl, processDispatchNotification, purgeInactiveDestinations, removeBroker, removeBrokerInClusterUpdate, removeConnection, removeDestination, removeDestinationInfo, removeSubscription, rollbackTransaction, sendToDeadLetterQueue, setAdminConnectionContext, setAllowTempAutoCreationOnSend, setBrokerId, setBrokerName, setKeepDurableSubsActive, stop

Methods inherited from class org.apache.activemq.broker.EmptyBroker

addSession, fastProducer, isFaultTolerantConfiguration, isFull, messageConsumed, messageDelivered, messageDiscarded, networkBridgeStarted, networkBridgeStopped, 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,
                   javax.management.ObjectName brokerObjectName,
                   TaskRunnerFactory taskRunnerFactory,
                   SystemUsage memoryManager,
                   DestinationFactory destinationFactory,
                   DestinationInterceptor destinationInterceptor,
                   Scheduler scheduler,
                   java.util.concurrent.ThreadPoolExecutor executor)
                    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(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 javax.management.ObjectName registerSubscription(ConnectionContext context,
                                               Subscription sub)

addConsumer

public Subscription addConsumer(ConnectionContext context,
                       ConsumerInfo info)
                         throws java.lang.Exception

Description copied from interface: Region

Adds a consumer.

Specified by:

addConsumer in interface Region

Overrides:

addConsumer in class RegionBroker

Parameters:

context - the environment the operation is being executed under.

Returns:

TODO

Throws:

java.lang.Exception - TODO

removeConsumer

public void removeConsumer(ConnectionContext context,
                  ConsumerInfo info)
                    throws java.lang.Exception

Description copied from interface: Region

Removes a consumer.

Specified by:

removeConsumer in interface Region

Overrides:

removeConsumer in class RegionBroker

Parameters:

context - the environment the operation is being executed under.

Throws:

java.lang.Exception - TODO

addProducer

public void addProducer(ConnectionContext context,
               ProducerInfo info)
                 throws java.lang.Exception

Description copied from interface: Broker

Adds a producer.

Specified by:

addProducer in interface Broker

Specified by:

addProducer in interface Region

Overrides:

addProducer in class RegionBroker

Parameters:

context - the enviorment the operation is being executed under.

Throws:

java.lang.Exception - TODO

removeProducer

public void removeProducer(ConnectionContext context,
                  ProducerInfo info)
                    throws java.lang.Exception

Description copied from interface: Broker

Removes a producer.

Specified by:

removeProducer in interface Broker

Specified by:

removeProducer in interface Region

Overrides:

removeProducer in class RegionBroker

Parameters:

context - the enviorment the operation is being executed under.

Throws:

java.lang.Exception - TODO

send

public void send(ProducerBrokerExchange exchange,
        Message message)
          throws java.lang.Exception

Description copied from interface: Region

Send a message to the broker to using the specified destination. The destination specified in the message does not need to match the destination the message is sent to. This is handy in case the message is being sent to a dead letter destination.

Specified by:

send in interface Region

Overrides:

send in class RegionBroker

Parameters:

exchange - the environment the operation is being executed under.

Throws:

java.lang.Exception - TODO

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

registerProducer

protected void registerProducer(javax.management.ObjectName key,
                    ActiveMQDestination dest,
                    ProducerView view)
                         throws java.lang.Exception

Throws:

java.lang.Exception

unregisterProducer

protected void unregisterProducer(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,
                          boolean addToInactive)
                               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,
                           Subscription subscription)

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<Message> 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()

getTopicProducers

protected javax.management.ObjectName[] getTopicProducers()

getQueueProducers

protected javax.management.ObjectName[] getQueueProducers()

getTemporaryTopicProducers

protected javax.management.ObjectName[] getTemporaryTopicProducers()

getTemporaryQueueProducers

protected javax.management.ObjectName[] getTemporaryQueueProducers()

getDynamicDestinationProducers

protected javax.management.ObjectName[] getDynamicDestinationProducers()

getContextBroker

public Broker getContextBroker()

setContextBroker

public void setContextBroker(Broker contextBroker)

registerSlowConsumerStrategy

public javax.management.ObjectName registerSlowConsumerStrategy(AbortSlowConsumerStrategy strategy)
                                                         throws javax.management.MalformedObjectNameException

Throws:

javax.management.MalformedObjectNameException

registerRecoveredTransactionMBean

public void registerRecoveredTransactionMBean(XATransaction transaction)

unregister

public void unregister(XATransaction transaction)

getSubscriberObjectName

public javax.management.ObjectName getSubscriberObjectName(Subscription key)

getSubscriber

public Subscription getSubscriber(javax.management.ObjectName key)

getQueueViews

public java.util.Map<javax.management.ObjectName,DestinationView> getQueueViews()