- public void setUp() {
- NotificationServiceSerializer serializer = new NotificationServiceSerializer();
- Map<String, Object> properties = Map.of(ConfigConstants.CONVERTER , serializer);
- serializer.configure(properties, false);
- mockProducer = new MockProducer<>(true, new StringSerializer(), serializer);
- converter = new JsonStringConverter<NotificationService>(
- getDataStoreContextUtil().getBindingDOMCodecServices());
- publisher = new Publisher("test",mockProducer);
+ public void setUp() throws ExecutionException, InterruptedException {
+ topicManager = TopicManager.getInstance();
+ converterService = new JsonStringConverter<>(getDataStoreContextUtil().getBindingDOMCodecServices());
+ converterAlarm = new JsonStringConverter<>(getDataStoreContextUtil().getBindingDOMCodecServices());
+ converterTapiService = new JsonStringConverter<>(getDataStoreContextUtil().getBindingDOMCodecServices());
+ NotificationServiceSerializer serializerService = new NotificationServiceSerializer();
+ NotificationAlarmServiceSerializer serializerAlarm = new NotificationAlarmServiceSerializer();
+ TapiNotificationSerializer serializerTapi = new TapiNotificationSerializer();
+ Map<String, Object> properties = Map.of(ConfigConstants.CONVERTER, converterService);
+ Map<String, Object> propertiesAlarm = Map.of(ConfigConstants.CONVERTER, converterAlarm);
+ Map<String, Object> propertiesTapi = Map.of(ConfigConstants.CONVERTER, converterTapiService);
+ serializerService.configure(properties, false);
+ serializerAlarm.configure(propertiesAlarm, false);
+ serializerTapi.configure(propertiesTapi, false);
+ mockProducer = new MockProducer<>(true, new StringSerializer(), serializerService);
+ mockAlarmProducer = new MockProducer<>(true, new StringSerializer(), serializerAlarm);
+ mockTapiProducer = new MockProducer<>(true, new StringSerializer(), serializerTapi);
+ publisherService = new Publisher<>("test", mockProducer);
+ publisherAlarm = new Publisher<>("test", mockAlarmProducer);
+ publisherTapiService = new Publisher<>("test", mockTapiProducer);
+ MockitoAnnotations.openMocks(this);
+ networkTransactionService = new NetworkTransactionImpl(
+ new RequestProcessor(getDataStoreContextUtil().getDataBroker()));
+ topicManager.setTapiConverter(converterTapiService);
+ NotificationServiceDataUtils.createTapiContext(networkTransactionService);
+ nbiNotificationsImpl = new NbiNotificationsImpl(converterService, converterAlarm, converterTapiService,
+ "localhost:8080", networkTransactionService, topicManager);