From 01578219e470c4cd9b6181c0615759a7118c0abb Mon Sep 17 00:00:00 2001 From: wasala Date: Mon, 9 Jul 2018 14:30:01 +0200 Subject: Refactor jsonParsing to reactive Already forwarded responsibility of creation Mono stream in function in DmaapConsumerJsonParser Change-Id: Ia03695c7e22575d078e169eeaa45ca1416c558a8 Issue-ID: DCAEGEN2-563 Signed-off-by: wasala --- .../onap/dcaegen2/services/prh/service/DmaapConsumerJsonParserTest.java | 2 ++ 1 file changed, 2 insertions(+) (limited to 'prh-app-server/src/test/java/org') diff --git a/prh-app-server/src/test/java/org/onap/dcaegen2/services/prh/service/DmaapConsumerJsonParserTest.java b/prh-app-server/src/test/java/org/onap/dcaegen2/services/prh/service/DmaapConsumerJsonParserTest.java index 32f5c1e2..ba01abfb 100644 --- a/prh-app-server/src/test/java/org/onap/dcaegen2/services/prh/service/DmaapConsumerJsonParserTest.java +++ b/prh-app-server/src/test/java/org/onap/dcaegen2/services/prh/service/DmaapConsumerJsonParserTest.java @@ -17,6 +17,7 @@ * limitations under the License. * ============LICENSE_END========================================================= */ + package org.onap.dcaegen2.services.prh.service; import static org.mockito.Mockito.spy; @@ -110,6 +111,7 @@ class DmaapConsumerJsonParserTest { JsonElement jsonElement = new JsonParser().parse(parsed); Mockito.doReturn(Optional.of(jsonElement.getAsJsonObject())) .when(dmaapConsumerJsonParser).getJsonObjectFromAnArray(jsonElement); + dmaapConsumerJsonParser.getJsonObject(Mono.just((message))); ConsumerDmaapModel consumerDmaapModel = dmaapConsumerJsonParser.getJsonObject(Mono.just((message))) .block(); //then -- cgit 1.2.3-korg