Bug fix in DMAAP message parsing for CMNotify

[ccsdk/sli/northbound.git] / dmaap-listener / src / main / java / org / onap / ccsdk / sli / northbound / dmaapclient / CMNotifyDmaapConsumer.java

diff --git a/dmaap-listener/src/main/java/org/onap/ccsdk/sli/northbound/dmaapclient/CMNotifyDmaapConsumer.java b/dmaap-listener/src/main/java/org/onap/ccsdk/sli/northbound/dmaapclient/CMNotifyDmaapConsumer.java
index e49e77e..fa14fbb 100644 (file)
--- a/dmaap-listener/src/main/java/org/onap/ccsdk/sli/northbound/dmaapclient/CMNotifyDmaapConsumer.java
+++ b/dmaap-listener/src/main/java/org/onap/ccsdk/sli/northbound/dmaapclient/CMNotifyDmaapConsumer.java
@@ -71,14 +71,10 @@ public class CMNotifyDmaapConsumer extends SdncDmaapConsumerImpl {
             return;
         }
 
-        JSONObject rpcMsgBodyNode = new JSONObject();
-
-        rpcMsgBodyNode.put(INPUT,payloadNode);
-
         String rpcMsgbody;
         try {
                ObjectMapper mapper = new ObjectMapper();
-                rpcMsgbody = mapper.writeValueAsString(rpcMsgBodyNode);
+                rpcMsgbody = "{\"input\":" + mapper.writeValueAsString(payloadNode) + "}";
 
         } catch (Exception e) {
             LOG.error("Unable to parse payload in CMNotify-DMAAP message", e);