- 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);
+ NotificationServiceSerializer serializerService = new NotificationServiceSerializer();
+ NotificationAlarmServiceSerializer serializerAlarm = new NotificationAlarmServiceSerializer();
+ Map<String, Object> properties = Map.of(ConfigConstants.CONVERTER, serializerService);
+ Map<String, Object> propertiesAlarm = Map.of(ConfigConstants.CONVERTER, serializerAlarm);
+ serializerService.configure(properties, false);
+ serializerAlarm.configure(propertiesAlarm, false);
+ mockProducer = new MockProducer<>(true, new StringSerializer(), serializerService);
+ mockAlarmProducer = new MockProducer<>(true, new StringSerializer(), serializerAlarm);
+ converterService = new JsonStringConverter<>(getDataStoreContextUtil().getBindingDOMCodecServices());
+ converterAlarm = new JsonStringConverter<>(getDataStoreContextUtil().getBindingDOMCodecServices());
+ publisherService = new Publisher<>("test", mockProducer);
+ publisherAlarm = new Publisher<>("test", mockAlarmProducer);