Fix bug in a JUnit nbinotifications test

Initialize correctly serializers used by kafka producers.

JIRA: TRNSPRTPCE-641
Signed-off-by: Gilles Thouenon <gilles.thouenon@orange.com>
Change-Id: Ie3abb9fc93669048e42187f32b9fca983bfd04d5

diff --git a/nbinotifications/src/test/java/org/opendaylight/transportpce/nbinotifications/producer/PublisherTest.java b/nbinotifications/src/test/java/org/opendaylight/transportpce/nbinotifications/producer/PublisherTest.java
index 86e33307bda1b2366405c2557a3f47219481f334..4b9e160f585428727d90592833295b15055f8f62 100644 (file)
--- a/nbinotifications/src/test/java/org/opendaylight/transportpce/nbinotifications/producer/PublisherTest.java
+++ b/nbinotifications/src/test/java/org/opendaylight/transportpce/nbinotifications/producer/PublisherTest.java
@@ -37,16 +37,16 @@ public class PublisherTest extends AbstractTest {
 
     @Before
     public void setUp() {
+        converterService = new JsonStringConverter<>(getDataStoreContextUtil().getBindingDOMCodecServices());
+        converterAlarm = new JsonStringConverter<>(getDataStoreContextUtil().getBindingDOMCodecServices());
         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);
+        Map<String, Object> properties = Map.of(ConfigConstants.CONVERTER, converterService);
+        Map<String, Object> propertiesAlarm = Map.of(ConfigConstants.CONVERTER, converterAlarm);
         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);
     }