Change-Id: I530c70159ef26bb3d3df11f23b3f89715c591efb
Issue-ID: NONRTRIC-195
Signed-off-by: PatrikBuhr <patrik.buhr@est.tech>
}
private DmaapMessageHandler getDmaapMessageHandler() throws IOException {
}
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);
AsyncRestClient agentClient = createRestClient(agentBaseUrl);
Properties dmaapPublisherProperties = applicationConfig.getDmaapPublisherConfig();
MRBatchingPublisher producer = getMessageRouterPublisher(dmaapPublisherProperties);
messageConsumerUnderTest.run();
messageConsumerUnderTest.run();
- verify(messageConsumerUnderTest).createRestClient("http://localhost:0");
+ verify(messageConsumerUnderTest).createRestClient("https://localhost:0");
verify(messageConsumerUnderTest).getMessageRouterPublisher(properties);
verify(messageHandlerMock).handleDmaapMsg("message");
verify(messageConsumerUnderTest).getMessageRouterPublisher(properties);
verify(messageHandlerMock).handleDmaapMsg("message");