diff options
Diffstat (limited to 'prh-app-server/src/test')
-rw-r--r-- | prh-app-server/src/test/java/org/onap/dcaegen2/services/prh/tasks/ScheduledTasksTest.java | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/prh-app-server/src/test/java/org/onap/dcaegen2/services/prh/tasks/ScheduledTasksTest.java b/prh-app-server/src/test/java/org/onap/dcaegen2/services/prh/tasks/ScheduledTasksTest.java index cefc5c76..346421ec 100644 --- a/prh-app-server/src/test/java/org/onap/dcaegen2/services/prh/tasks/ScheduledTasksTest.java +++ b/prh-app-server/src/test/java/org/onap/dcaegen2/services/prh/tasks/ScheduledTasksTest.java @@ -139,14 +139,17 @@ class ScheduledTasksTest { @Test void whenPnfHasActiveService_OnlyPostToPnfUpdateShouldBePerformed() throws SSLException, PrhTaskException { //given + Mono<ConsumerDmaapModel> consumerModel = Mono.just(DMAAP_MODEL); + given(consumer.execute()).willReturn(Flux.just(DMAAP_MODEL)); given(aaiQuery.execute(any())).willReturn(Mono.just(true)); + given(aaiProducer.execute(DMAAP_MODEL)).willReturn(consumerModel); //when sut.scheduleMainPrhEventTask(); //then - verifyThatPnfUpdateWasNotSentToAai(); + verifyThatPnfUpdateWasSentToAai(); verifyIfLogicalLinkWasNotCreated(); verifyThatPnfModelWasNotSentDmaapPnfReadyTopic(); verifyThatPnfModelWasSentDmaapPnfUpdateTopic(); |