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

Author: vintagewang

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

@@ -33,7 +33,6 @@
 import com.alibaba.rocketmq.common.message.MessageExt;
 import com.alibaba.rocketmq.common.message.MessageQueue;
 import com.alibaba.rocketmq.common.protocol.body.ClusterInfo;
-import com.alibaba.rocketmq.common.protocol.body.ConsumeByWho;
 import com.alibaba.rocketmq.common.protocol.body.ConsumeMessageDirectlyResult;
 import com.alibaba.rocketmq.common.protocol.body.ConsumerConnection;
 import com.alibaba.rocketmq.common.protocol.body.ConsumerRunningInfo;
@@ -252,12 +251,6 @@ public List<String> getNameServerAddressList() {
     }
 
 
-    @Override
-    public ConsumeByWho whoConsumeTheMessage(String msgId) {
-        return this.defaultMQAdminExtImpl.whoConsumeTheMessage(msgId);
-    }
-
-
     @Override
     public TopicList fetchAllTopicList() throws RemotingException, MQClientException, InterruptedException {
         return this.defaultMQAdminExtImpl.fetchAllTopicList();

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

@@ -51,7 +51,6 @@
 import com.alibaba.rocketmq.common.namesrv.NamesrvUtil;
 import com.alibaba.rocketmq.common.protocol.ResponseCode;
 import com.alibaba.rocketmq.common.protocol.body.ClusterInfo;
-import com.alibaba.rocketmq.common.protocol.body.ConsumeByWho;
 import com.alibaba.rocketmq.common.protocol.body.ConsumeMessageDirectlyResult;
 import com.alibaba.rocketmq.common.protocol.body.ConsumerConnection;
 import com.alibaba.rocketmq.common.protocol.body.ConsumerRunningInfo;
@@ -375,13 +374,6 @@ public List<String> getNameServerAddressList() {
     }
 
 
-    @Override
-    public ConsumeByWho whoConsumeTheMessage(String msgId) {
-        // TODO Auto-generated method stub
-        return null;
-    }
-
-
     @Override
     public TopicList fetchAllTopicList() throws RemotingException, MQClientException, InterruptedException {
         return this.mqClientInstance.getMQClientAPIImpl().getTopicListFromNameServer(3000);

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

@@ -31,7 +31,6 @@
 import com.alibaba.rocketmq.common.message.MessageExt;
 import com.alibaba.rocketmq.common.message.MessageQueue;
 import com.alibaba.rocketmq.common.protocol.body.ClusterInfo;
-import com.alibaba.rocketmq.common.protocol.body.ConsumeByWho;
 import com.alibaba.rocketmq.common.protocol.body.ConsumeMessageDirectlyResult;
 import com.alibaba.rocketmq.common.protocol.body.ConsumerConnection;
 import com.alibaba.rocketmq.common.protocol.body.ConsumerRunningInfo;
@@ -254,15 +253,6 @@ public int wipeWritePermOfBroker(final String namesrvAddr, String brokerName)
             RemotingTimeoutException, InterruptedException, MQClientException;
 
 
-    /**
-     * 查看某个订阅组被谁消费了
-     * 
-     * @param msgId
-     * @return
-     */
-    public ConsumeByWho whoConsumeTheMessage(final String msgId);
-
-
     /**
      * 向Name Server增加一个配置项
      *