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
Method Summary |
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 javax.management.ObjectName |
createObjectName(ActiveMQDestination destName)
|
protected javax.management.ObjectName |
createObjectName(ProducerInfo producerInfo,
java.lang.String connectionClientId)
|
protected javax.management.ObjectName |
createObjectName(XATransaction transaction)
|
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()
|
Subscription |
getSubscriber(javax.management.ObjectName key)
|
protected java.util.List<Message> |
getSubscriberMessages(SubscriptionView view)
|
javax.management.ObjectName |
getSubscriberObjectName(Subscription key)
|
static java.lang.String |
getSubscriptionObjectName(ConsumerInfo info,
java.lang.String connectionClientId,
javax.management.ObjectName brokerJmxObjectName)
|
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, getRoot, getScheduler, getTempDataStore, getTempQueueRegion, getTempTopicRegion, getTopicRegion, getVmConnectorURI, isAllowTempAutoCreationOnSend, isEqual, isExpired, isKeepDurableSubsActive, isSlaveBroker, 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 |
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
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)
getSubscriptionObjectName
public static java.lang.String getSubscriptionObjectName(ConsumerInfo info,
java.lang.String connectionClientId,
javax.management.ObjectName brokerJmxObjectName)
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)
createObjectName
protected javax.management.ObjectName createObjectName(ActiveMQDestination destName)
throws javax.management.MalformedObjectNameException
- Throws:
javax.management.MalformedObjectNameException
createObjectName
protected javax.management.ObjectName createObjectName(ProducerInfo producerInfo,
java.lang.String connectionClientId)
throws javax.management.MalformedObjectNameException
- Throws:
javax.management.MalformedObjectNameException
registerSlowConsumerStrategy
public javax.management.ObjectName registerSlowConsumerStrategy(AbortSlowConsumerStrategy strategy)
throws javax.management.MalformedObjectNameException
- Throws:
javax.management.MalformedObjectNameException
createObjectName
protected javax.management.ObjectName createObjectName(XATransaction transaction)
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)
Copyright © 2005-2015. All Rights Reserved.