summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--dmaap-listener/src/main/java/org/onap/ccsdk/sli/northbound/dmaapclient/CMNotifyDmaapConsumer.java6
1 files changed, 1 insertions, 5 deletions
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 e49e77ea8..fa14fbb24 100644
--- 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);