@Test public void testReportUndoneMsgs() { UndoneMsgs undoneMsgs = new UndoneMsgs(); undoneMsgs.setConsumerGroup("default-group"); undoneMsgs.setTopic("unit-test"); undoneMsgs.setUndoneMsgsDelayTimeMills(30000); undoneMsgs.setUndoneMsgsSingleMQ(1); undoneMsgs.setUndoneMsgsTotal(100); defaultMonitorListener.reportUndoneMsgs(undoneMsgs); }
@Override public void reportUndoneMsgs(UndoneMsgs undoneMsgs) { log.info(String.format(LOG_PREFIX + "reportUndoneMsgs: %s", undoneMsgs)); }
DefaultMonitorListener implements MonitorListener { @Override public void reportUndoneMsgs(UndoneMsgs undoneMsgs) { log.info(String.format(LOG_PREFIX + "reportUndoneMsgs: %s", undoneMsgs)); } }
DefaultMonitorListener implements MonitorListener { @Override public void reportUndoneMsgs(UndoneMsgs undoneMsgs) { log.info(String.format(LOG_PREFIX + "reportUndoneMsgs: %s", undoneMsgs)); } DefaultMonitorListener(); }
DefaultMonitorListener implements MonitorListener { @Override public void reportUndoneMsgs(UndoneMsgs undoneMsgs) { log.info(String.format(LOG_PREFIX + "reportUndoneMsgs: %s", undoneMsgs)); } 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 reportUndoneMsgs(UndoneMsgs undoneMsgs) { log.info(String.format(LOG_PREFIX + "reportUndoneMsgs: %s", undoneMsgs)); } 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();  }