diff options
| author |   Sandeep Shah <sandeeplinux1068@gmail.com> | 2020-05-22 23:06:07 -0500 |
|---|---|---|
| committer |   Dan Timoney <dtimoney@att.com> | 2020-05-26 08:51:12 -0400 |
| commit | 97892f35cd3a28dce2982d7f9a8830811f052178 (patch) | |
| tree | 1f9480be6dca48e3227d34a27f44694a1188a72f /dmaap-listener/src/main | |
| parent | c8734908fee2b0fce1a0e014b105517366cd082c (diff) | |
Bug fix in DMAAP message parsing for CMNotify
Minor bug fix in the DMAAP message for CMNotify
Issue-ID: CCSDK-2383
Signed-off-by: SandeepLinux <Sandeep.Shah@ibm.com>
Change-Id: Ia080adafecf6d6b3a12682aaab3f244a33a16de5
Signed-off-by: Dan Timoney <dtimoney@att.com>
Diffstat (limited to 'dmaap-listener/src/main')
| -rw-r--r-- | dmaap-listener/src/main/java/org/onap/ccsdk/sli/northbound/dmaapclient/CMNotifyDmaapConsumer.java | 6 |
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 e49e77ea..fa14fbb2 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); |