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

Author: vintagewang

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

@@ -43,7 +43,7 @@ public static void main(String[] args) throws MQClientException, InterruptedExce
          * 例如消息写入Master成功，但是Slave不成功，这种情况消息属于成功，但是对于个别应用如果对消息可靠性要求极高，<br>
          * 需要对这种情况做处理。另外，消息可能会存在发送失败的情况，失败重试由应用来处理。
          */
-        for(int i = 0; i < 1000; i++)
+        for(int i = 0; i < 10; i++)
         try {
             {
                 Message msg = new Message("TopicTest1",// topic

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

@@ -38,8 +38,8 @@ public static void main(String[] args) throws InterruptedException, MQClientExce
          * 注意：ConsumerGroupName需要由应用来保证唯一
          */
         DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("CID_222");
-        consumer.setNamesrvAddr("10.235.170.7:9877");
-        //consumer.setNamesrvAddr("127.0.0.1:9876");
+        // consumer.setNamesrvAddr("10.235.170.7:9877");
+        // consumer.setNamesrvAddr("127.0.0.1:9876");
 
         /**
          * 订阅指定topic下tags分别等于TagA或TagC或TagD
@@ -51,7 +51,6 @@ public static void main(String[] args) throws InterruptedException, MQClientExce
          */
         consumer.subscribe("TopicTest2", "*");
         consumer.subscribe("TopicTest3", "*");
-        consumer.subscribe("BenchmarkTest", "*");
 
         /**
          * 设置Consumer第一次启动是从队列头部开始消费还是队列尾部开始消费<br>
@@ -67,7 +66,8 @@ public static void main(String[] args) throws InterruptedException, MQClientExce
             @Override
             public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs,
                     ConsumeConcurrentlyContext context) {
-                //System.out.println(Thread.currentThread().getName() + " Receive New Messages: " + msgs);
+                // System.out.println(Thread.currentThread().getName() +
+                // " Receive New Messages: " + msgs);
 
                 MessageExt msg = msgs.get(0);
                 if (msg.getTopic().equals("TopicTest1")) {

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

@@ -166,6 +166,7 @@ public static void queryById(final DefaultMQAdminExt admin, final String msgId)
             }
         }
         catch (Exception e) {
+            e.printStackTrace();
         }
     }