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)
|
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(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[] |
getInactiveDurableTopicSubscribers()
|
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(Subscription sub,
java.lang.String connectionClientId,
javax.management.ObjectName brokerJmxObjectName)
|
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 |
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 |
setContextBroker(Broker contextBroker)
|
void |
start()
|
void |
unregister(ActiveMQDestination destName)
|
protected void |
unregisterDestination(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, addProducer, 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, isEqual, isExpired, isKeepDurableSubsActive, isSlaveBroker, isStopped, messageExpired, messagePull, postProcessDispatch, prepareTransaction, preProcessDispatch, processConsumerControl, processDispatchNotification, purgeInactiveDestinations, removeAdvisoryTopics, removeBroker, removeBrokerInClusterUpdate, removeConnection, 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, 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(Subscription sub,
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
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,
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)
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()
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
registerSlowConsumerStrategy
public javax.management.ObjectName registerSlowConsumerStrategy(AbortSlowConsumerStrategy strategy)
throws javax.management.MalformedObjectNameException
- Throws:
javax.management.MalformedObjectNameException
getSubscriberObjectName
public javax.management.ObjectName getSubscriberObjectName(Subscription key)
getSubscriber
public Subscription getSubscriber(javax.management.ObjectName key)
Copyright © 2005-2012. All Rights Reserved.