From: Marcin Migdal <marcin.migdal@nokia.com>
Date: Wed, 27 Mar 2019 12:38:53 +0000 (+0100)
Subject: Support "Empty" from DMaap Simulator
X-Git-Tag: 1.2.2~14
X-Git-Url: https://gerrit.onap.org/r/gitweb?a=commitdiff_plain;h=refs%2Fchanges%2F83%2F83483%2F1;p=dcaegen2%2Fservices%2Fprh.git

Support "Empty" from DMaap Simulator

Change-Id: Idaf9f5df34017aad6c7f2a3aa1e65b971ff5d5bc
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 d9a673ca..531a8e5f 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
@@ -24,6 +24,7 @@ import com.google.gson.JsonArray;
 import com.google.gson.JsonElement;
 import com.google.gson.JsonObject;
 import com.google.gson.JsonParser;
+import com.google.gson.JsonPrimitive;
 import org.onap.dcaegen2.services.prh.exceptions.DmaapNotFoundException;
 import org.onap.dcaegen2.services.prh.model.ConsumerDmaapModel;
 import org.onap.dcaegen2.services.prh.model.ImmutableConsumerDmaapModel;
@@ -87,6 +88,11 @@ public class DmaapConsumerJsonParser {
 
         LOGGER.debug("DmaapConsumerJsonParser input for parsing: {}",jsonElement);
 
+        if(jsonElement instanceof JsonPrimitive) {
+            LOGGER.debug("Response from DMaaP is Json primitive {}", jsonElement);
+            return Flux.empty();
+        }
+
         if(jsonElement instanceof JsonObject)
             return create(Flux.just((JsonObject) jsonElement));