From 565963aba8bd36ec97af4cd9566cb630dd24942d Mon Sep 17 00:00:00 2001 From: Gilles Thouenon Date: Thu, 3 Mar 2022 11:35:44 +0100 Subject: [PATCH] Fix bug in a JUnit nbinotifications test Initialize correctly serializers used by kafka producers. JIRA: TRNSPRTPCE-641 Signed-off-by: Gilles Thouenon Change-Id: Ie3abb9fc93669048e42187f32b9fca983bfd04d5 --- .../nbinotifications/producer/PublisherTest.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) 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 86e33307b..4b9e160f5 100644 --- 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 properties = Map.of(ConfigConstants.CONVERTER, serializerService); - Map propertiesAlarm = Map.of(ConfigConstants.CONVERTER, serializerAlarm); + Map properties = Map.of(ConfigConstants.CONVERTER, converterService); + Map 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); } -- 2.36.6