AggregatorImpl implements Aggregator { @Override public void publishNotification(Notification notification) throws DispatchException { LOGGER.info("Publish global notification:\n {}", notification.notificationToString()); Set<NotificationProcessor> notificationProcessors = getNotificationProcessorManager().getProcessors(); for (NotificationProcessor notificationProcessor : notificationProcessors) { LOGGER.info("Processor: {}", notificationProcessor); notificationProcessor.publishNotification(notification); } } AggregatorImpl(); @Override String dispatchRequest(NetconfClientInfo clientInfo, String netconfRequest); @Override void publishNotification(Notification notification); @Override void publishNotification(String deviceName, Notification notification); @Override void addProcessor(Set<ModuleIdentifier> moduleIdentifiers, GlobalRequestProcessor globalRequestProcessor); @Override void addProcessor(String deviceType, Set<ModuleIdentifier> moduleIdentifiers,
                             DeviceConfigProcessor deviceConfigProcessor); @Override void addProcessor(NotificationProcessor notificationProcessor); @Override void removeProcessor(GlobalRequestProcessor globalRequestProcessor); @Override void removeProcessor(DeviceConfigProcessor deviceConfigProcessor); @Override void removeProcessor(NotificationProcessor notificationProcessor); @Override void removeProcessor(String deviceType, Set<ModuleIdentifier> moduleIdentifiers,
                                DeviceConfigProcessor deviceConfigProcessor); @Override Set<String> getSystemCapabilities(); @Override void registerDeviceManager(DeviceManagementProcessor deviceManagementProcessor); @Override void unregisterDeviceManager(); @Override Set<ProcessorCapability> getProcessorCapabilities(); @Override Set<ModuleIdentifier> getModuleIdentifiers();  }
@Test public void publishNotificationTest() throws Exception { Notification notification = new NetconfNotification(DocumentUtils.stringToDocument(NOTIFICATION)); m_aggregator.publishNotification(DEVICE_NAME_TEST, notification); verify(m_notificationProcessor).publishNotification(any(Notification.class)); }