#491 增加消息id被谁消费api，扩展id查询命令

Author: vintagewang

rocketmq-example/src/main/java/com/alibaba/rocketmq/example/simple/Producer.java

@@ -30,7 +30,7 @@ public static void main(String[] args) throws MQClientException, InterruptedExce
          * 因为服务器会回查这个Group下的任意一个Producer
          */
         DefaultMQProducer producer = new DefaultMQProducer("ProducerGroupName");
-        producer.setNamesrvAddr("10.235.170.7:9877");
+        //producer.setNamesrvAddr("10.235.170.7:9877");
         /**
          * Producer对象在使用之前必须要调用start初始化，初始化一次即可<br>
          * 注意：切记不可以在每次发送消息时，都调用start方法

rocketmq-tools/src/main/java/com/alibaba/rocketmq/tools/admin/DefaultMQAdminExt.java

@@ -422,9 +422,9 @@ public ConsumeMessageDirectlyResult consumeMessageDirectly(String consumerGroup,
 
 
     @Override
-    public List<MessageTrack> messageTrackDetail(MessageExt msg) {
-        // TODO Auto-generated method stub
-        return null;
+    public List<MessageTrack> messageTrackDetail(MessageExt msg) throws RemotingException, MQClientException,
+            InterruptedException, MQBrokerException {
+        return this.defaultMQAdminExtImpl.messageTrackDetail(msg);
     }
 
 }

rocketmq-tools/src/main/java/com/alibaba/rocketmq/tools/admin/DefaultMQAdminExtImpl.java

@@ -45,7 +45,6 @@
 import com.alibaba.rocketmq.common.admin.OffsetWrapper;
 import com.alibaba.rocketmq.common.admin.RollbackStats;
 import com.alibaba.rocketmq.common.admin.TopicStatsTable;
-import com.alibaba.rocketmq.common.filter.FilterAPI;
 import com.alibaba.rocketmq.common.help.FAQUrl;
 import com.alibaba.rocketmq.common.message.MessageExt;
 import com.alibaba.rocketmq.common.message.MessageQueue;
@@ -770,7 +769,6 @@ public List<MessageTrack> messageTrackDetail(MessageExt msg) throws RemotingExce
         GroupList groupList = this.queryTopicConsumeByWho(msg.getTopic());
 
         for (String group : groupList.getGroupList()) {
-
             // 查询连接
             MessageTrack mt = new MessageTrack();
             mt.setConsumerGroup(group);
@@ -813,8 +811,10 @@ public List<MessageTrack> messageTrackDetail(MessageExt msg) throws RemotingExce
             catch (Exception e) {
                 mt.setExceptionDesc(RemotingHelper.exceptionSimpleDesc(e));
             }
+
+            result.add(mt);
         }
 
-        return null;
+        return result;
     }
 }

rocketmq-tools/src/main/java/com/alibaba/rocketmq/tools/command/message/QueryMsgByIdSubCommand.java

@@ -154,9 +154,18 @@ public static void queryById(final DefaultMQAdminExt admin, final String msgId)
             bodyTmpFilePath//
             );
 
-        List<MessageTrack> mtdList = admin.messageTrackDetail(msg);
-        for (MessageTrack mt : mtdList) {
-            System.out.println(mt);
+        try {
+            List<MessageTrack> mtdList = admin.messageTrackDetail(msg);
+            if (mtdList.isEmpty()) {
+                System.out.println("No Consumer");
+            }
+            else {
+                for (MessageTrack mt : mtdList) {
+                    System.out.println(mt);
+                }
+            }
+        }
+        catch (Exception e) {
         }
     }