@Test public void testReportDeleteMsgsEvent() { DeleteMsgsEvent deleteMsgsEvent = new DeleteMsgsEvent(); deleteMsgsEvent.setEventTimestamp(System.currentTimeMillis()); deleteMsgsEvent.setOffsetMovedEvent(new OffsetMovedEvent()); defaultMonitorListener.reportDeleteMsgsEvent(deleteMsgsEvent); }
@Override public void reportDeleteMsgsEvent(DeleteMsgsEvent deleteMsgsEvent) { log.info(String.format(LOG_PREFIX + "reportDeleteMsgsEvent: %s", deleteMsgsEvent)); }
DefaultMonitorListener implements MonitorListener { @Override public void reportDeleteMsgsEvent(DeleteMsgsEvent deleteMsgsEvent) { log.info(String.format(LOG_PREFIX + "reportDeleteMsgsEvent: %s", deleteMsgsEvent)); } }
DefaultMonitorListener implements MonitorListener { @Override public void reportDeleteMsgsEvent(DeleteMsgsEvent deleteMsgsEvent) { log.info(String.format(LOG_PREFIX + "reportDeleteMsgsEvent: %s", deleteMsgsEvent)); } DefaultMonitorListener(); }
DefaultMonitorListener implements MonitorListener { @Override public void reportDeleteMsgsEvent(DeleteMsgsEvent deleteMsgsEvent) { log.info(String.format(LOG_PREFIX + "reportDeleteMsgsEvent: %s", deleteMsgsEvent)); } 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 reportDeleteMsgsEvent(DeleteMsgsEvent deleteMsgsEvent) { log.info(String.format(LOG_PREFIX + "reportDeleteMsgsEvent: %s", deleteMsgsEvent)); } 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();  }