@Test public void testReportFailedMsgs() { FailedMsgs failedMsgs = new FailedMsgs(); failedMsgs.setTopic("unit-test"); failedMsgs.setConsumerGroup("default-consumer"); failedMsgs.setFailedMsgsTotalRecently(2); defaultMonitorListener.reportFailedMsgs(failedMsgs); }
@Override public void reportFailedMsgs(FailedMsgs failedMsgs) { log.info(String.format(LOG_PREFIX + "reportFailedMsgs: %s", failedMsgs)); }
DefaultMonitorListener implements MonitorListener { @Override public void reportFailedMsgs(FailedMsgs failedMsgs) { log.info(String.format(LOG_PREFIX + "reportFailedMsgs: %s", failedMsgs)); } }
DefaultMonitorListener implements MonitorListener { @Override public void reportFailedMsgs(FailedMsgs failedMsgs) { log.info(String.format(LOG_PREFIX + "reportFailedMsgs: %s", failedMsgs)); } DefaultMonitorListener(); }
DefaultMonitorListener implements MonitorListener { @Override public void reportFailedMsgs(FailedMsgs failedMsgs) { log.info(String.format(LOG_PREFIX + "reportFailedMsgs: %s", failedMsgs)); } 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 reportFailedMsgs(FailedMsgs failedMsgs) { log.info(String.format(LOG_PREFIX + "reportFailedMsgs: %s", failedMsgs)); } 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();  }