org.apache.activemq.broker.jmx
Class ManagedRegionBroker
java.lang.Object
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 |
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 |
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
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 © 2010 Apache Software Foundation. All Rights Reserved.