diff options
| author |   wasala <przemyslaw.wasala@nokia.com> | 2018-07-09 14:30:01 +0200 |
|---|---|---|
| committer | wasala <przemyslaw.wasala@nokia.com> | 2018-08-07 09:58:22 +0200 |
| commit | 01578219e470c4cd9b6181c0615759a7118c0abb (patch) | |
| tree | f0dd62d9d4fb96c688ef4e0985b5f5a8f4e21f65 /prh-app-server/src/test/java/org | |
| parent | e74228673c9c5241a9e901726716f77aacb2711f (diff) | |
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 <przemyslaw.wasala@nokia.com>
Diffstat (limited to 'prh-app-server/src/test/java/org')
| -rw-r--r-- | prh-app-server/src/test/java/org/onap/dcaegen2/services/prh/service/DmaapConsumerJsonParserTest.java | 2 |
1 files changed, 2 insertions, 0 deletions
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 |