NotificationForwarder implements NotificationProcessor { @Override public void publishNotification(Notification notification) throws DispatchException { m_notificationService.sendNotification("CONFIG_CHANGE", notification); } NotificationForwarder(Aggregator aggregator, NotificationService notificationService); void init(); void destroy(); @Override void publishNotification(Notification notification);  }
@Test public void publishNotification() throws Exception { Notification notification = new NetconfNotification(DocumentUtils.stringToDocument(NOTIFICATION)); m_notificatonForwarder.publishNotification(notification); verify(m_notificationService).sendNotification(eq("CONFIG_CHANGE"), any(Notification.class)); }