-
Bug
-
Resolution: Done
-
High
-
Casablanca Release
In the class org.openecomp.mso.bpmn.infrastructure.pnf.dmaap.PnfEventReadyDmaapClient
there is the code
[ 155|https://gerrit.onap.org/r/gitweb?p=so.git;a=blob;f=bpmn/MSOInfrastructureBPMN/src/main/java/org/openecomp/mso/bpmn/infrastructure/pnf/dmaap/PnfEventReadyDmaapClient.java;h=830574bad4fc4ee8ab8b339e90c8d0f4504e8b63;hb=HEAD#l155] private Optional<String> getCorrelationIdFromResponse(HttpResponse response) throws IOException {
[ 156|https://gerrit.onap.org/r/gitweb?p=so.git;a=blob;f=bpmn/MSOInfrastructureBPMN/src/main/java/org/openecomp/mso/bpmn/infrastructure/pnf/dmaap/PnfEventReadyDmaapClient.java;h=830574bad4fc4ee8ab8b339e90c8d0f4504e8b63;hb=HEAD#l156] if (response.getStatusLine().getStatusCode() == 200) {
[ 157|https://gerrit.onap.org/r/gitweb?p=so.git;a=blob;f=bpmn/MSOInfrastructureBPMN/src/main/java/org/openecomp/mso/bpmn/infrastructure/pnf/dmaap/PnfEventReadyDmaapClient.java;h=830574bad4fc4ee8ab8b339e90c8d0f4504e8b63;hb=HEAD#l157] String responseString = EntityUtils.toString(response.getEntity(), "UTF-8");
[ 158|https://gerrit.onap.org/r/gitweb?p=so.git;a=blob;f=bpmn/MSOInfrastructureBPMN/src/main/java/org/openecomp/mso/bpmn/infrastructure/pnf/dmaap/PnfEventReadyDmaapClient.java;h=830574bad4fc4ee8ab8b339e90c8d0f4504e8b63;hb=HEAD#l158] if (responseString != null)
[ 161|https://gerrit.onap.org/r/gitweb?p=so.git;a=blob;f=bpmn/MSOInfrastructureBPMN/src/main/java/org/openecomp/mso/bpmn/infrastructure/pnf/dmaap/PnfEventReadyDmaapClient.java;h=830574bad4fc4ee8ab8b339e90c8d0f4504e8b63;hb=HEAD#l161] }
[ 162|https://gerrit.onap.org/r/gitweb?p=so.git;a=blob;f=bpmn/MSOInfrastructureBPMN/src/main/java/org/openecomp/mso/bpmn/infrastructure/pnf/dmaap/PnfEventReadyDmaapClient.java;h=830574bad4fc4ee8ab8b339e90c8d0f4504e8b63;hb=HEAD#l162] return Optional.empty();
[ 163|https://gerrit.onap.org/r/gitweb?p=so.git;a=blob;f=bpmn/MSOInfrastructureBPMN/src/main/java/org/openecomp/mso/bpmn/infrastructure/pnf/dmaap/PnfEventReadyDmaapClient.java;h=830574bad4fc4ee8ab8b339e90c8d0f4504e8b63;hb=HEAD#l163] }
The problem is that the data that comes back from the DMaaP topics in the response is a escaped json message so it need to be unescaped before processing
This could be copied from the class DmaapConsumerJsonParser in the org.onap.dcaegen2.services.prh.service as it uses the gsonParser to do it.