summaryrefslogtreecommitdiffstats
path: root/prh-app-server/src/test
diff options
context:
space:
mode:
authorpwielebs <piotr.wielebski@nokia.com>2018-10-11 15:11:23 +0200
committerpwielebs <piotr.wielebski@nokia.com>2018-10-11 15:11:23 +0200
commit00c3ed839d7e46f991a7d7948eab142d6bb9b699 (patch)
tree2c890c2c459ac9dda20794fc10fefd655b02fc87 /prh-app-server/src/test
parent172fd71106f9674f52871a5b91908673eaf5a3de (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.java10
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) {