完善Consumer 监控

Author: vintagewang

rocketmq-tools/src/main/java/com/alibaba/rocketmq/tools/monitor/DefaultMonitorListener.java

@@ -1,19 +1,18 @@
 package com.alibaba.rocketmq.tools.monitor;
 
+import java.util.Map;
+
 import com.alibaba.rocketmq.common.protocol.body.ConsumerRunningInfo;
 
 
 public class DefaultMonitorListener implements MonitorListener {
 
     public DefaultMonitorListener() {
-        // TODO Auto-generated constructor stub
     }
 
 
     @Override
     public void beginRound() {
-        // TODO Auto-generated method stub
-
     }
 
 
@@ -36,14 +35,11 @@ public void reportDeleteMsgsEvent(DeleteMsgsEvent deleteMsgsEvent) {
 
 
     @Override
-    public void reportConsumerRunningInfo(ConsumerRunningInfo consumerRunningInfo) {
-        // TODO Auto-generated method stub
-
+    public void reportConsumerRunningInfo(Map<String, ConsumerRunningInfo> criTable) {
     }
 
 
     @Override
     public void endRound() {
-        // TODO Auto-generated method stub
     }
 }

rocketmq-tools/src/main/java/com/alibaba/rocketmq/tools/monitor/MonitorListener.java

@@ -1,5 +1,7 @@
 package com.alibaba.rocketmq.tools.monitor;
 
+import java.util.Map;
+
 import com.alibaba.rocketmq.common.protocol.body.ConsumerRunningInfo;
 
 
@@ -34,7 +36,7 @@ public interface MonitorListener {
     /**
      * 汇报Consumer内部运行数据结构
      */
-    public void reportConsumerRunningInfo(ConsumerRunningInfo consumerRunningInfo);
+    public void reportConsumerRunningInfo(Map<String/* clientId */, ConsumerRunningInfo> criTable);
 
 
     /**