com.alibaba.rocketmq.tools.monitor
类 DefaultMonitorListener

java.lang.Object
  com.alibaba.rocketmq.tools.monitor.DefaultMonitorListener

所有已实现的接口：

MonitorListener

public class DefaultMonitorListener
extends Object
implements MonitorListener

构造方法摘要

DefaultMonitorListener()

方法摘要

void	beginRound() 开始一轮监控
void	endRound() 结束一轮监控
void	reportConsumerRunningInfo(TreeMap<String,ConsumerRunningInfo> criTable) 汇报Consumer内部运行数据结构
void	reportDeleteMsgsEvent(DeleteMsgsEvent deleteMsgsEvent) 汇报消息删除情况
void	reportFailedMsgs(FailedMsgs failedMsgs) 汇报消费失败情况
void	reportUndoneMsgs(UndoneMsgs undoneMsgs) 汇报消息堆积情况

从类 java.lang.Object 继承的方法

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造方法详细信息

DefaultMonitorListener

public DefaultMonitorListener()

方法详细信息

beginRound

public void beginRound()

从接口 MonitorListener 复制的描述

开始一轮监控

指定者：

接口 MonitorListener 中的 beginRound

reportUndoneMsgs

public void reportUndoneMsgs(UndoneMsgs undoneMsgs)

从接口 MonitorListener 复制的描述

汇报消息堆积情况

指定者：

接口 MonitorListener 中的 reportUndoneMsgs

reportFailedMsgs

public void reportFailedMsgs(FailedMsgs failedMsgs)

从接口 MonitorListener 复制的描述

汇报消费失败情况

指定者：

接口 MonitorListener 中的 reportFailedMsgs

reportDeleteMsgsEvent

public void reportDeleteMsgsEvent(DeleteMsgsEvent deleteMsgsEvent)

从接口 MonitorListener 复制的描述

汇报消息删除情况

指定者：

接口 MonitorListener 中的 reportDeleteMsgsEvent

reportConsumerRunningInfo

public void reportConsumerRunningInfo(TreeMap<String,ConsumerRunningInfo> criTable)

从接口 MonitorListener 复制的描述

汇报Consumer内部运行数据结构

指定者：

接口 MonitorListener 中的 reportConsumerRunningInfo

endRound

public void endRound()

从接口 MonitorListener 复制的描述

结束一轮监控

指定者：

接口 MonitorListener 中的 endRound