diff options
| author |   grabinsk <maciej.grabinski@nokia.com> | 2019-05-28 11:23:53 +0200 |
|---|---|---|
| committer | grabinsk <maciej.grabinski@nokia.com> | 2019-05-29 09:32:47 +0200 |
| commit | 37444e2753f351cfe22b4651bcf777b833aeba92 (patch) | |
| tree | 9280875024a947f1b644aa9f1c93bc81799d1201 /prh-app-server/src/test/java/org/onap/dcaegen2/services/prh/tasks/DmaapPublisherTaskImplTest.java | |
| parent | 37dd2cb2d2ad38ad1e6dd83f3ff5b40bc2c0f614 (diff) | |
SSL key loading for Dmaap client
Change-Id: I65b3d0bcd6735af655c9243f20f3596ce8f03aca
Issue-ID: DCAEGEN2-1501
Signed-off-by: grabinsk <maciej.grabinski@nokia.com>
Diffstat (limited to 'prh-app-server/src/test/java/org/onap/dcaegen2/services/prh/tasks/DmaapPublisherTaskImplTest.java')
| -rw-r--r-- | prh-app-server/src/test/java/org/onap/dcaegen2/services/prh/tasks/DmaapPublisherTaskImplTest.java | 13 |
1 files changed, 2 insertions, 11 deletions
diff --git a/prh-app-server/src/test/java/org/onap/dcaegen2/services/prh/tasks/DmaapPublisherTaskImplTest.java b/prh-app-server/src/test/java/org/onap/dcaegen2/services/prh/tasks/DmaapPublisherTaskImplTest.java index 6f38d87d..b1f97a3c 100644 --- a/prh-app-server/src/test/java/org/onap/dcaegen2/services/prh/tasks/DmaapPublisherTaskImplTest.java +++ b/prh-app-server/src/test/java/org/onap/dcaegen2/services/prh/tasks/DmaapPublisherTaskImplTest.java @@ -22,7 +22,6 @@ package org.onap.dcaegen2.services.prh.tasks; import com.google.gson.JsonElement; import com.google.gson.JsonParser; -import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.extension.ExtendWith; import org.junit.jupiter.api.function.Executable; @@ -44,7 +43,6 @@ import reactor.test.StepVerifier; import static org.junit.jupiter.api.Assertions.assertThrows; import static org.mockito.ArgumentMatchers.eq; import static org.mockito.Mockito.verify; -import static org.mockito.Mockito.when; /** * @author <a href="mailto:przemyslaw.wasala@nokia.com">Przemysław Wąsala</a> on 5/17/18 @@ -57,22 +55,15 @@ class DmaapPublisherTaskImplTest { private MessageRouterPublishRequest mrRequest = createMRRequest(); @Mock - private static MessageRouterPublisherResolver messageRouterPublisherClientResolver; - @Mock private static MessageRouterPublisher messageRouterPublisher; @Captor private ArgumentCaptor<Flux<JsonElement>> fluxCaptor; - @BeforeEach - void beforeEach() { - when(messageRouterPublisherClientResolver.resolveClient()).thenReturn(messageRouterPublisher); - } - @Test void execute_whenPassedObjectDoesntFit_ThrowsPrhTaskException() { //given - dmaapPublisherTask = new DmaapPublisherTaskImpl(() -> mrRequest, messageRouterPublisherClientResolver); + dmaapPublisherTask = new DmaapPublisherTaskImpl(() -> mrRequest, () -> messageRouterPublisher); //when Executable executableFunction = () -> dmaapPublisherTask.execute(null); //then @@ -82,7 +73,7 @@ class DmaapPublisherTaskImplTest { @Test void execute_whenPassedObjectFits_ReturnsCorrectStatus() throws DmaapNotFoundException { //given - dmaapPublisherTask = new DmaapPublisherTaskImpl(() -> mrRequest, messageRouterPublisherClientResolver); + dmaapPublisherTask = new DmaapPublisherTaskImpl(() -> mrRequest, () -> messageRouterPublisher); //when dmaapPublisherTask.execute(createConsumerDmaapModel()); //then |