aboutsummaryrefslogtreecommitdiffstats
path: root/sdc-distribution-client/src/main/java/org/onap/sdc/impl/DistributionClientImpl.java
diff options
context:
space:
mode:
authorefiacor <fiachra.corcoran@est.tech>2023-05-08 18:17:03 +0100
committerefiacor <fiachra.corcoran@est.tech>2023-06-13 18:56:19 +0100
commitac4baf28eab0a4412810f02237b981933c985e95 (patch)
treec9fc3c3a6c35e5481b261ff2acc912bdf708fa12 /sdc-distribution-client/src/main/java/org/onap/sdc/impl/DistributionClientImpl.java
parent289c0ceb2b3b0565ae19014a4cfa06a1bf10ccc3 (diff)
[SDC-DISTRO-CLIENT] SSL config updates
Signed-off-by: efiacor <fiachra.corcoran@est.tech> Change-Id: Iacaf5072241e56bf72db13acef0f533814ae8989 Issue-ID: SDC-4476
Diffstat (limited to 'sdc-distribution-client/src/main/java/org/onap/sdc/impl/DistributionClientImpl.java')
-rw-r--r--sdc-distribution-client/src/main/java/org/onap/sdc/impl/DistributionClientImpl.java3
1 files changed, 2 insertions, 1 deletions
diff --git a/sdc-distribution-client/src/main/java/org/onap/sdc/impl/DistributionClientImpl.java b/sdc-distribution-client/src/main/java/org/onap/sdc/impl/DistributionClientImpl.java
index a34ba1e..0c05b58 100644
--- a/sdc-distribution-client/src/main/java/org/onap/sdc/impl/DistributionClientImpl.java
+++ b/sdc-distribution-client/src/main/java/org/onap/sdc/impl/DistributionClientImpl.java
@@ -30,6 +30,7 @@ import fj.data.Either;
import java.lang.reflect.Type;
import java.nio.charset.StandardCharsets;
import java.util.ArrayList;
+import java.util.Arrays;
import java.util.Collections;
import java.util.List;
import java.util.UUID;
@@ -324,7 +325,7 @@ public class DistributionClientImpl implements IDistributionClient {
errorWrapper.setInnerElement(kafkaData.right().value());
} else {
KafkaDataResponse kafkaDataResponse = kafkaData.left().value();
- configuration.setMsgBusAddress(Collections.singletonList(kafkaDataResponse.getKafkaBootStrapServer()));
+ configuration.setMsgBusAddress(kafkaDataResponse.getKafkaBootStrapServer());
configuration.setNotificationTopicName(kafkaDataResponse.getDistrNotificationTopicName());
configuration.setStatusTopicName(kafkaDataResponse.getDistrStatusTopicName());
log.debug("MessageBus cluster info retrieved successfully {}", kafkaData.left().value());