From 90b9931873e13247e937a6d4b5206c65033b306e Mon Sep 17 00:00:00 2001 From: elinuxhenrik Date: Wed, 19 Sep 2018 08:49:28 +0200 Subject: Use correct Content Type from DMaaP Add the Content Type to the header the DMaaP consumer uses to get the fileReady event from DMAaaP to prevent formatting problems. Change-Id: Iedf38b7542e5709a78f383d31c75e7b95aa56cfe Issue-ID: DCAEGEN2-825 Signed-off-by: elinuxhenrik --- .../collectors/datafile/service/DmaapConsumerJsonParser.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'datafile-app-server') diff --git a/datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/service/DmaapConsumerJsonParser.java b/datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/service/DmaapConsumerJsonParser.java index 72e7d497..e4afd3ae 100644 --- a/datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/service/DmaapConsumerJsonParser.java +++ b/datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/service/DmaapConsumerJsonParser.java @@ -63,11 +63,11 @@ public class DmaapConsumerJsonParser { /** * Extract info from string and create @see {@link FileData}. * - * @param monoMessage - results from DMaaP + * @param rawMessage - results from DMaaP * @return reactive Mono with an array of FileData */ - public Mono> getJsonObject(Mono monoMessage) { - return monoMessage.flatMap(this::getJsonParserMessage).flatMap(this::createJsonConsumerModel); + public Mono> getJsonObject(Mono rawMessage) { + return rawMessage.flatMap(this::getJsonParserMessage).flatMap(this::createJsonConsumerModel); } private Mono getJsonParserMessage(String message) { -- cgit 1.2.3-korg