com.alibaba.rocketmq.tools.monitor
类 MonitorService

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

public class MonitorService
extends Object

构造方法摘要

MonitorService(MonitorConfig monitorConfig, MonitorListener monitorListener, RPCHook rpcHook)

方法摘要

void	doMonitorWork()
static void	main(String[] args)
static void	main0(String[] args, RPCHook rpcHook)
void	reportConsumerRunningInfo(String consumerGroup)
void	shutdown()
void	start()

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

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

构造方法详细信息

MonitorService

public MonitorService(MonitorConfig monitorConfig,
                      MonitorListener monitorListener,
                      RPCHook rpcHook)

方法详细信息

start

public void start()
           throws MQClientException

抛出：

MQClientException

shutdown

public void shutdown()

doMonitorWork

public void doMonitorWork()
                   throws RemotingException,
                          MQClientException,
                          InterruptedException

抛出：

RemotingException

MQClientException

InterruptedException

reportConsumerRunningInfo

public void reportConsumerRunningInfo(String consumerGroup)
                               throws InterruptedException,
                                      MQBrokerException,
                                      RemotingException,
                                      MQClientException

抛出：

InterruptedException

MQBrokerException

RemotingException

MQClientException

main

public static void main(String[] args)
                 throws MQClientException

抛出：

MQClientException

main0

public static void main0(String[] args,
                         RPCHook rpcHook)
                  throws MQClientException

抛出：

MQClientException