Refactor NBINotifications and serviceHandlerImpl

[transportpce.git] / dmaap-client / src / main / java / org / opendaylight / transportpce / dmaap / client / resource / config / PublishNotificationProcessServiceSerializer.java

diff --git a/dmaap-client/src/main/java/org/opendaylight/transportpce/dmaap/client/resource/config/PublishNotificationServiceSerializer.java b/dmaap-client/src/main/java/org/opendaylight/transportpce/dmaap/client/resource/config/PublishNotificationProcessServiceSerializer.java
similarity index 74%
rename from dmaap-client/src/main/java/org/opendaylight/transportpce/dmaap/client/resource/config/PublishNotificationServiceSerializer.java
rename to dmaap-client/src/main/java/org/opendaylight/transportpce/dmaap/client/resource/config/PublishNotificationProcessServiceSerializer.java
index 0b282b4c99d297f24fe4f94d5efc562dd54a17cb..b9b650ce0573324cf069bacf26528c588e5db6e1 100644 (file)
--- a/dmaap-client/src/main/java/org/opendaylight/transportpce/dmaap/client/resource/config/PublishNotificationServiceSerializer.java
+++ b/dmaap-client/src/main/java/org/opendaylight/transportpce/dmaap/client/resource/config/PublishNotificationProcessServiceSerializer.java
@@ -11,19 +11,19 @@ import com.fasterxml.jackson.core.JsonGenerator;
 import com.fasterxml.jackson.databind.SerializerProvider;
 import com.fasterxml.jackson.databind.ser.std.StdSerializer;
 import java.io.IOException;
-import org.opendaylight.yang.gen.v1.nbi.notifications.rev210628.PublishNotificationService;
+import org.opendaylight.yang.gen.v1.nbi.notifications.rev210813.PublishNotificationProcessService;
 
 // This class is a temporary workaround while waiting jackson
 // support in yang tools https://git.opendaylight.org/gerrit/c/yangtools/+/94852
-public class PublishNotificationServiceSerializer extends StdSerializer<PublishNotificationService> {
+public class PublishNotificationProcessServiceSerializer extends StdSerializer<PublishNotificationProcessService> {
     private static final long serialVersionUID = 1L;
 
-    public PublishNotificationServiceSerializer() {
-        super(PublishNotificationService.class);
+    public PublishNotificationProcessServiceSerializer() {
+        super(PublishNotificationProcessService.class);
     }
 
     @Override
-    public void serialize(PublishNotificationService value, JsonGenerator gen, SerializerProvider provider)
+    public void serialize(PublishNotificationProcessService value, JsonGenerator gen, SerializerProvider provider)
             throws IOException {
         if (value != null) {
             gen.writeStartObject();
@@ -31,7 +31,7 @@ public class PublishNotificationServiceSerializer extends StdSerializer<PublishN
             gen.writeStringField("message", value.getMessage());
             gen.writeStringField("response-failed", value.getResponseFailed());
             gen.writeStringField("service-name", value.getServiceName());
-            gen.writeStringField("topic", value.getTopic());
+            gen.writeStringField("publisher-name", value.getPublisherName());
             if (value.getOperationalState() != null) {
                 gen.writeStringField("operational-state", value.getOperationalState().getName());
             }