NotificationForwarder implements NotificationProcessor { public void init() { try { m_aggregator.addProcessor(this); } catch (DispatchException ex) { LOGGER.error("NotificationForwarder init failed"); } } NotificationForwarder(Aggregator aggregator, NotificationService notificationService); void init(); void destroy(); @Override void publishNotification(Notification notification);  }
@Test public void init() throws Exception { m_notificatonForwarder.init(); verify(m_aggregator).addProcessor(m_notificatonForwarder); }