Repository: incubator-rocketmq-externals Updated Branches: refs/heads/master 820538727 -> 0e069f25a
Update console's readme and consumer's code, closes apache/incubator-rocketmq-externals#1 Project: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-externals/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-externals/commit/0e069f25 Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-externals/tree/0e069f25 Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-externals/diff/0e069f25 Branch: refs/heads/master Commit: 0e069f25a5c0953ac82283b138eb39c61b094ee5 Parents: 8205387 Author: StyleTang <[email protected]> Authored: Wed Mar 15 23:07:36 2017 +0800 Committer: yukon <[email protected]> Committed: Wed Mar 15 23:07:36 2017 +0800 ---------------------------------------------------------------------- rocketmq-console-ng/README.md | 14 +++++++------- .../console/service/impl/ConsumerServiceImpl.java | 9 +++++++-- 2 files changed, 14 insertions(+), 9 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-externals/blob/0e069f25/rocketmq-console-ng/README.md ---------------------------------------------------------------------- diff --git a/rocketmq-console-ng/README.md b/rocketmq-console-ng/README.md index ed8c567..ac27dc3 100644 --- a/rocketmq-console-ng/README.md +++ b/rocketmq-console-ng/README.md @@ -1,8 +1,8 @@ -#RocketMQ-Console-Ng[](https://travis-ci.org/rocketmq/rocketmq-console-ng) [](https://coveralls.io/github/rocketmq/rocketmq-console-ng?branch=master) +## RocketMQ-Console-Ng[](https://travis-ci.org/rocketmq/rocketmq-console-ng) [](https://coveralls.io/github/rocketmq/rocketmq-console-ng?branch=master) [](https://www.apache.org/licenses/LICENSE-2.0.html) -#How To Install +## How To Install -## With Docker +### With Docker * get docker image @@ -21,7 +21,7 @@ docker pull styletang/rocketmq-console-ng docker run -e "JAVA_OPTS=-Drocketmq.namesrv.addr=127.0.0.1:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false" -p 8080:8080 -t styletang/rocketmq-console-ng ``` -## Without Docker +### Without Docker require java 1.7 ``` mvn spring-boot:run @@ -32,7 +32,7 @@ mvn clean package -Dmaven.test.skip=true java -jar target/rocketmq-console-ng-1.0.0.jar ``` -### Tips +#### Tips * if you download package slow,you can change maven's mirror(maven's settings.xml) ``` @@ -49,13 +49,13 @@ java -jar target/rocketmq-console-ng-1.0.0.jar * if you use the rocketmq < 3.5.8,please add -Dcom.rocketmq.sendMessageWithVIPChannel=false when you start rocketmq-console-ng(or you can change it in ops page) * change the rocketmq.config.namesrvAddr in resource/application.properties.(or you can change it in ops page) -#UserGuide +## UserGuide [English](https://github.com/rocketmq/rocketmq-console-ng/blob/master/doc/1_0_0/UserGuide_EN.md) [ä¸æ](https://github.com/rocketmq/rocketmq-console-ng/blob/master/doc/1_0_0/UserGuide_CN.md) -#Communicate With Us +## Communicate With Us * QQ Group:535273860 * You can communicate with us use QQ.(or send us issue / pull request) * You can join us and make a contribute for rocketmq-console-ng. http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-externals/blob/0e069f25/rocketmq-console-ng/src/main/java/org/apache/rocketmq/console/service/impl/ConsumerServiceImpl.java ---------------------------------------------------------------------- diff --git a/rocketmq-console-ng/src/main/java/org/apache/rocketmq/console/service/impl/ConsumerServiceImpl.java b/rocketmq-console-ng/src/main/java/org/apache/rocketmq/console/service/impl/ConsumerServiceImpl.java index 4485a7d..715cbf5 100644 --- a/rocketmq-console-ng/src/main/java/org/apache/rocketmq/console/service/impl/ConsumerServiceImpl.java +++ b/rocketmq-console-ng/src/main/java/org/apache/rocketmq/console/service/impl/ConsumerServiceImpl.java @@ -137,7 +137,7 @@ public class ConsumerServiceImpl extends AbstractCommonService implements Consum public List<TopicConsumerInfo> queryConsumeStatsList(final String topic, String groupName) { ConsumeStats consumeStats = null; try { - consumeStats = mqAdminExt.examineConsumeStats(groupName); + consumeStats = mqAdminExt.examineConsumeStats(groupName, topic); } catch (Exception e) { throw propagate(e); @@ -190,7 +190,12 @@ public class ConsumerServiceImpl extends AbstractCommonService implements Consum try { GroupList groupList = mqAdminExt.queryTopicConsumeByWho(topic); for (String group : groupList.getGroupList()) { - List<TopicConsumerInfo> topicConsumerInfoList = queryConsumeStatsList(topic, group); + List<TopicConsumerInfo> topicConsumerInfoList = null; + try { + topicConsumerInfoList = queryConsumeStatsList(topic, group); + } + catch (Exception ignore) { + } group2ConsumerInfoMap.put(group, CollectionUtils.isEmpty(topicConsumerInfoList) ? new TopicConsumerInfo(topic) : topicConsumerInfoList.get(0)); } return group2ConsumerInfoMap;
