Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

https://issues.apache.org/jira/browse/AMQ-4237 - new jmx and web console - consumers on connection 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1430283 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Bosanac Dejan 2013-01-08 13:51:56 +00:00
parent e3626e19bc
commit f4f033c91a
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
activemq-web/src/main/java/org/apache/activemq/web/BrokerFacadeSupport.java
View File

@ -194,8 +194,8 @@ public abstract class BrokerFacadeSupport implements BrokerFacade {
public Collection<SubscriptionViewMBean> getConsumersOnConnection(String connectionName) throws Exception { public Collection<SubscriptionViewMBean> getConsumersOnConnection(String connectionName) throws Exception {
connectionName = StringUtils.replace(connectionName, ":", "_"); connectionName = StringUtils.replace(connectionName, ":", "_");
String brokerName = getBrokerName(); String brokerName = getBrokerName();
ObjectName query = new ObjectName("org.apache.activemq:BrokerName=" + brokerName ObjectName query = new ObjectName("org.apache.activemq:type=Broker,brokerName=" + brokerName
+ ",Type=Subscription,clientId=" + connectionName + ",*"); + ",*,endpoint=Consumer,clientId=" + connectionName);
Set<ObjectName> queryResult = queryNames(query, null); Set<ObjectName> queryResult = queryNames(query, null);
return getManagedObjects(queryResult.toArray(new ObjectName[queryResult.size()]), SubscriptionViewMBean.class); return getManagedObjects(queryResult.toArray(new ObjectName[queryResult.size()]), SubscriptionViewMBean.class);
} }