@Test public void testBeginRound() { defaultMonitorListener.beginRound(); }
@Override public void beginRound() { log.info(LOG_PREFIX + "=========================================beginRound"); }
DefaultMonitorListener implements MonitorListener { @Override public void beginRound() { log.info(LOG_PREFIX + "=========================================beginRound"); } }
DefaultMonitorListener implements MonitorListener { @Override public void beginRound() { log.info(LOG_PREFIX + "=========================================beginRound"); } DefaultMonitorListener(); }
DefaultMonitorListener implements MonitorListener { @Override public void beginRound() { log.info(LOG_PREFIX + "=========================================beginRound"); } DefaultMonitorListener(); @Override void beginRound(); @Override void reportUndoneMsgs(UndoneMsgs undoneMsgs); @Override void reportFailedMsgs(FailedMsgs failedMsgs); @Override void reportDeleteMsgsEvent(DeleteMsgsEvent deleteMsgsEvent); @Override void reportConsumerRunningInfo(TreeMap<String, ConsumerRunningInfo> criTable); @Override void endRound(); }
DefaultMonitorListener implements MonitorListener { @Override public void beginRound() { log.info(LOG_PREFIX + "=========================================beginRound"); } DefaultMonitorListener(); @Override void beginRound(); @Override void reportUndoneMsgs(UndoneMsgs undoneMsgs); @Override void reportFailedMsgs(FailedMsgs failedMsgs); @Override void reportDeleteMsgsEvent(DeleteMsgsEvent deleteMsgsEvent); @Override void reportConsumerRunningInfo(TreeMap<String, ConsumerRunningInfo> criTable); @Override void endRound();  }