import java.util.Map;
import org.apache.kafka.common.serialization.Deserializer;
import org.opendaylight.transportpce.common.converter.JsonStringConverter;
-import org.opendaylight.yang.gen.v1.nbi.notifications.rev201130.get.notifications.service.output.NotificationService;
-import org.opendaylight.yang.gen.v1.nbi.notifications.rev201130.get.notifications.service.output.NotificationServiceBuilder;
+import org.opendaylight.yang.gen.v1.nbi.notifications.rev210628.get.notifications.service.output.NotificationService;
+import org.opendaylight.yang.gen.v1.nbi.notifications.rev210628.get.notifications.service.output.NotificationServiceBuilder;
import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
import org.opendaylight.yangtools.yang.data.codec.gson.JSONCodecFactorySupplier;
import org.slf4j.Logger;
public class NotificationServiceDeserializer implements Deserializer<NotificationService> {
private static final Logger LOG = LoggerFactory.getLogger(NotificationServiceDeserializer.class);
private JsonStringConverter<org.opendaylight.yang.gen.v1
- .nbi.notifications.rev201130.NotificationService> converter;
+ .nbi.notifications.rev210628.NotificationService> converter;
@SuppressWarnings("unchecked")
@Override
if (configs.containsKey(ConfigConstants.CONVERTER)
&& configs.get(ConfigConstants.CONVERTER) instanceof JsonStringConverter<?>) {
converter = (JsonStringConverter<org.opendaylight.yang.gen.v1
- .nbi.notifications.rev201130.NotificationService>) configs
+ .nbi.notifications.rev210628.NotificationService>) configs
.get(ConfigConstants.CONVERTER);
}
}
// we have to map it to
// org.opendaylight.yang.gen
// .v1.nbi.notifications.rev201130.get.notifications.service.output.NotificationService
- org.opendaylight.yang.gen.v1.nbi.notifications.rev201130.NotificationService mappedString = converter
+ org.opendaylight.yang.gen.v1.nbi.notifications.rev210628.NotificationService mappedString = converter
.createDataObjectFromJsonString(YangInstanceIdentifier.of(
- org.opendaylight.yang.gen.v1.nbi.notifications.rev201130.NotificationService.QNAME),
+ org.opendaylight.yang.gen.v1.nbi.notifications.rev210628.NotificationService.QNAME),
value,
JSONCodecFactorySupplier.RFC7951);
if (mappedString != null) {