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)
|
CompositeData[] |
browse(SubscriptionView view)
|
TabularData |
browseAsTable(SubscriptionView view)
|
protected void |
buildExistingSubscriptions()
|
protected 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 ObjectName[] |
getDurableTopicSubscribers()
|
protected ObjectName[] |
getInactiveDurableTopicSubscribers()
|
protected ObjectName[] |
getQueues()
|
protected ObjectName[] |
getQueueSubscribers()
|
protected List |
getSubscriberMessages(SubscriptionView view)
|
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, 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,
MBeanServer mbeanServer,
ObjectName brokerObjectName,
TaskRunnerFactory taskRunnerFactory,
UsageManager memoryManager,
DestinationFactory destinationFactory,
DestinationInterceptor destinationInterceptor)
throws IOException
- Throws:
IOException
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(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 ObjectName registerSubscription(ConnectionContext context,
Subscription sub)
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 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 © 2011 Apache Software Foundation. All Rights Reserved.