summaryrefslogtreecommitdiffstats
path: root/prh-app-server/src/test
diff options
context:
space:
mode:
authorPiotr Jaszczyk <piotr.jaszczyk@nokia.com>2019-05-22 14:56:15 +0000
committerGerrit Code Review <gerrit@onap.org>2019-05-22 14:56:15 +0000
commite2f12ecdee8f9320e23b95a1671cb7c8fcacf361 (patch)
treeabc1d6e5a2e0f157bb84777aa4685d346e2c9874 /prh-app-server/src/test
parent41216decc9e167ee85aff6391f67dcf4b94f489c (diff)
parent97b4eac83d68e1b44b9ce628bcc9440d5f3353ef (diff)
Merge "Remove deprecated method from PRH"
Diffstat (limited to 'prh-app-server/src/test')
-rw-r--r--prh-app-server/src/test/java/org/onap/dcaegen2/services/prh/tasks/ScheduledTasksTest.java22
1 files changed, 12 insertions, 10 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 9a3099c5..9acbadd7 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
@@ -19,7 +19,6 @@
*/
package org.onap.dcaegen2.services.prh.tasks;
-import org.apache.http.HttpResponse;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
@@ -28,6 +27,7 @@ import org.onap.dcaegen2.services.prh.exceptions.PrhTaskException;
import org.onap.dcaegen2.services.prh.integration.junit5.mockito.MockitoExtension;
import org.onap.dcaegen2.services.prh.model.ConsumerDmaapModel;
import org.onap.dcaegen2.services.prh.model.ImmutableConsumerDmaapModel;
+import org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.model.MessageRouterPublishResponse;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
@@ -38,7 +38,9 @@ import java.util.Map;
import static org.mockito.ArgumentMatchers.any;
import static org.mockito.ArgumentMatchers.anyString;
import static org.mockito.BDDMockito.given;
-import static org.mockito.Mockito.*;
+import static org.mockito.Mockito.atLeastOnce;
+import static org.mockito.Mockito.never;
+import static org.mockito.Mockito.verify;
@ExtendWith(MockitoExtension.class)
public class ScheduledTasksTest {
@@ -151,20 +153,20 @@ public class ScheduledTasksTest {
verifyThatPnfModelWasSentDmaapPnfUpdateTopic();
}
- private void verifyThatPnfModelWasNotSentDmaapPnfReadyTopic() {
- verify(readyPublisher, never()).executeWithApache(DMAAP_MODEL);
+ private void verifyThatPnfModelWasNotSentDmaapPnfReadyTopic() throws PrhTaskException {
+ verify(readyPublisher, never()).execute(DMAAP_MODEL);
}
- private Mono<HttpResponse> verifyThatPnfModelWasNotSentDmaapPnfUpdateTopic() {
- return verify(updatePublisher, never()).executeWithApache(DMAAP_MODEL);
+ private Flux<MessageRouterPublishResponse> verifyThatPnfModelWasNotSentDmaapPnfUpdateTopic() throws PrhTaskException {
+ return verify(updatePublisher, never()).execute(DMAAP_MODEL);
}
- private void verifyThatPnfModelWasSentDmaapPnfReadyTopic() {
- verify(readyPublisher, atLeastOnce()).executeWithApache(DMAAP_MODEL);
+ private void verifyThatPnfModelWasSentDmaapPnfReadyTopic() throws PrhTaskException {
+ verify(readyPublisher, atLeastOnce()).execute(DMAAP_MODEL);
}
- private Mono<HttpResponse> verifyThatPnfModelWasSentDmaapPnfUpdateTopic() {
- return verify(updatePublisher, atLeastOnce()).executeWithApache(DMAAP_MODEL);
+ private Flux<MessageRouterPublishResponse> verifyThatPnfModelWasSentDmaapPnfUpdateTopic() throws PrhTaskException {
+ return verify(updatePublisher, atLeastOnce()).execute(DMAAP_MODEL);
}
private void verifyThatPnfUpdateWasNotSentToAai() throws PrhTaskException, SSLException {