| commit | 2647dd6e2451dab9f758034c9189271c40ecf600 | [log] [tgz] |
|---|---|---|
| author | Marcin Migdal <marcin.migdal@nokia.com> | Wed Mar 27 13:05:51 2019 +0100 |
| committer | Marcin Migdal <marcin.migdal@nokia.com> | Wed Mar 27 13:05:51 2019 +0100 |
| tree | 486c701ae03763051cbf270dc4eac821c2ead5e3 | |
| parent | 7fed7d3348f36cbd4698caa2c987f413f72745f5 [diff] |
Add logging to DmaapConsumerJsonParser for input Change-Id: I42d7ab9beab80f8ea07aff3eb05a43b64836f75c Issue-ID: DCAEGEN2-1361 Signed-off-by: Marcin Migdal <marcin.migdal@nokia.com>
diff --git a/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/service/DmaapConsumerJsonParser.java b/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/service/DmaapConsumerJsonParser.java index 7f2cc69..d9a673c 100644 --- a/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/service/DmaapConsumerJsonParser.java +++ b/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/service/DmaapConsumerJsonParser.java
@@ -85,6 +85,8 @@ private Flux<ConsumerDmaapModel> getConsumerDmaapModelFromJsonArray(JsonElement jsonElement) { + LOGGER.debug("DmaapConsumerJsonParser input for parsing: {}",jsonElement); + if(jsonElement instanceof JsonObject) return create(Flux.just((JsonObject) jsonElement));