diff options
author | 2018-10-11 15:11:23 +0200 | |
---|---|---|
committer | 2018-10-11 15:11:23 +0200 | |
commit | 00c3ed839d7e46f991a7d7948eab142d6bb9b699 (patch) | |
tree | 2c890c2c459ac9dda20794fc10fefd655b02fc87 /prh-app-server/src/test | |
parent | 172fd71106f9674f52871a5b91908673eaf5a3de (diff) |
Bug fix due to failures on CSIT tests1.1.0
Change-Id: Ib35b9448178f906f47527e49bdd14be75a17e578
Issue-ID: DCAEGEN2-866
Signed-off-by: pwielebs <piotr.wielebski@nokia.com>
Diffstat (limited to 'prh-app-server/src/test')
-rw-r--r-- | prh-app-server/src/test/java/org/onap/dcaegen2/services/prh/tasks/DmaapConsumerTaskImplTest.java | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/prh-app-server/src/test/java/org/onap/dcaegen2/services/prh/tasks/DmaapConsumerTaskImplTest.java b/prh-app-server/src/test/java/org/onap/dcaegen2/services/prh/tasks/DmaapConsumerTaskImplTest.java index 689a732c..c17e2543 100644 --- a/prh-app-server/src/test/java/org/onap/dcaegen2/services/prh/tasks/DmaapConsumerTaskImplTest.java +++ b/prh-app-server/src/test/java/org/onap/dcaegen2/services/prh/tasks/DmaapConsumerTaskImplTest.java @@ -109,25 +109,25 @@ class DmaapConsumerTaskImplTest { //given prepareMocksForDmaapConsumer(Optional.empty()); - //then - StepVerifier.create(dmaapConsumerTask.execute("Sample input")).expectSubscription() - .expectError(DmaapEmptyResponseException.class).verify(); + //when + Flux<ConsumerDmaapModel> response = dmaapConsumerTask.execute("Sample input"); + //then verify(dMaaPConsumerReactiveHttpClient, times(1)).getDMaaPConsumerResponse(); + assertEquals(null, response.blockFirst()); } @Test void whenPassedObjectFits_ReturnsCorrectResponse() { //given prepareMocksForDmaapConsumer(Optional.of(message)); + //when Flux<ConsumerDmaapModel> response = dmaapConsumerTask.execute("Sample input"); //then verify(dMaaPConsumerReactiveHttpClient, times(1)).getDMaaPConsumerResponse(); assertEquals(consumerDmaapModel, response.blockFirst()); - - } private void prepareMocksForDmaapConsumer(Optional<String> message) { |