+ rpcRegistration = rpcProviderService.registerRpcImplementations(
+ new GetNotificationsProcessServiceImpl(converterService, subscriberServer),
+ new GetNotificationsAlarmServiceImpl(converterAlarmService, subscriberServer),
+ new GetSupportedNotificationTypesImpl(this),
+ new CreateNotificationSubscriptionServiceImpl(this, topicManager),
+ new DeleteNotificationSubscriptionServiceImpl(networkTransactionService, topicManager),
+ new GetNotificationSubscriptionServiceDetailsImpl(this),
+ new GetNotificationSubscriptionServiceListImpl(this),
+ new GetNotificationListImpl(converterTapiService, subscriberServer, networkTransactionService,
+ topicManager));
+
+ NbiNotificationsHandler notificationsListener = new NbiNotificationsHandler(
+ topicManager.getProcessTopicMap(), topicManager.getAlarmTopicMap(), topicManager.getTapiTopicMap());
+ listenerRegistration = notificationService.registerCompositeListener(
+ notificationsListener.getCompositeListener());
+ topicManager.setNbiNotificationsListener(notificationsListener);