Fixed so that DMAAP client uses https 03/3503/1
authorPatrikBuhr <patrik.buhr@est.tech>
Tue, 28 Apr 2020 13:18:39 +0000 (15:18 +0200)
committerPatrikBuhr <patrik.buhr@est.tech>
Tue, 28 Apr 2020 13:19:09 +0000 (15:19 +0200)
Change-Id: I530c70159ef26bb3d3df11f23b3f89715c591efb
Issue-ID: NONRTRIC-195
Signed-off-by: PatrikBuhr <patrik.buhr@est.tech>
policy-agent/src/main/java/org/oransc/policyagent/dmaap/DmaapMessageConsumer.java
policy-agent/src/test/java/org/oransc/policyagent/dmaap/DmaapMessageConsumerTest.java

index f03aa58..da209a8 100644 (file)
@@ -110,7 +110,7 @@ public class DmaapMessageConsumer implements Runnable {
     }
 
     private DmaapMessageHandler getDmaapMessageHandler() throws IOException {
-        String agentBaseUrl = "http://localhost:" + this.localServerPort;
+        String agentBaseUrl = "https://localhost:" + this.localServerPort;
         AsyncRestClient agentClient = createRestClient(agentBaseUrl);
         Properties dmaapPublisherProperties = applicationConfig.getDmaapPublisherConfig();
         MRBatchingPublisher producer = getMessageRouterPublisher(dmaapPublisherProperties);
index 153c4ec..8dd3647 100644 (file)
@@ -170,7 +170,7 @@ public class DmaapMessageConsumerTest {
 
         messageConsumerUnderTest.run();
 
-        verify(messageConsumerUnderTest).createRestClient("http://localhost:0");
+        verify(messageConsumerUnderTest).createRestClient("https://localhost:0");
         verify(messageConsumerUnderTest).getMessageRouterPublisher(properties);
 
         verify(messageHandlerMock).handleDmaapMsg("message");