From f14578b9c5d9a98cceb5342d69b0326289b1690c Mon Sep 17 00:00:00 2001 From: Jim Hahn Date: Sat, 27 Jul 2019 08:20:17 -0400 Subject: Add addTopic(List) New services are typically configured using TopicParameters. These are converted into Properties before being passed to TopicEndpoint.addTopic(), which then converts them into BusTopicParams before configuring a given topic. Added TopicEndpoint.addTopic(List), which makes it possible to configure the topics without going into the intermediate Properties. Furthermore, because TopicParams is a subclass of BusTopicParams, no conversion is needed for that either, so the TopicParams can be passed directly into the configuration classes. Incorporated changes from review. Change-Id: Id87e2c6812e36ae1a3ac680e6b35208667971782 Issue-ID: POLICY-1953 Signed-off-by: Jim Hahn --- .../event/comm/bus/UebTopicPropertyBuilder.java | 25 ++++++++++++++++++++++ 1 file changed, 25 insertions(+) (limited to 'policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/UebTopicPropertyBuilder.java') diff --git a/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/UebTopicPropertyBuilder.java b/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/UebTopicPropertyBuilder.java index 6119284f..cb5507e5 100644 --- a/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/UebTopicPropertyBuilder.java +++ b/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/UebTopicPropertyBuilder.java @@ -45,6 +45,10 @@ import static org.onap.policy.common.endpoints.properties.PolicyEndPointProperti import static org.onap.policy.common.endpoints.properties.PolicyEndPointProperties.PROPERTY_TOPIC_SOURCE_FETCH_LIMIT_SUFFIX; import static org.onap.policy.common.endpoints.properties.PolicyEndPointProperties.PROPERTY_TOPIC_SOURCE_FETCH_TIMEOUT_SUFFIX; +import java.util.Arrays; +import lombok.Getter; +import org.onap.policy.common.endpoints.parameters.TopicParameters; + public class UebTopicPropertyBuilder extends TopicPropertyBuilder { public static final String SERVER = "my-server"; @@ -53,6 +57,9 @@ public class UebTopicPropertyBuilder extends TopicPropertyBuilder { public static final String MY_AAF_MECHID = "my-aaf-mechid"; public static final String MY_AAF_PASS = "my-aaf-passwd"; + @Getter + private TopicParameters params = new TopicParameters(); + /** * Constructs the object. * @@ -87,6 +94,24 @@ public class UebTopicPropertyBuilder extends TopicPropertyBuilder { setTopicProperty(PROPERTY_TOPIC_SINK_PARTITION_KEY_SUFFIX, MY_PARTITION); setTopicProperty(PROPERTY_TOPIC_SERVERS_SUFFIX, SERVER); + params.setTopicCommInfrastructure("ueb"); + params.setTopic(topic); + params.setEffectiveTopic(MY_EFFECTIVE_TOPIC); + params.setConsumerGroup(MY_CONS_GROUP); + params.setConsumerInstance(MY_CONS_INST); + params.setManaged(true); + params.setUseHttps(true); + params.setUserName(MY_AAF_MECHID); + params.setPassword(MY_AAF_PASS); + params.setAftEnvironment(MY_AFT_ENV); + params.setAllowSelfSignedCerts(true); + params.setApiKey(MY_API_KEY); + params.setApiSecret(MY_API_SECRET); + params.setFetchLimit(MY_FETCH_LIMIT); + params.setFetchTimeout(MY_FETCH_TIMEOUT); + params.setPartitionId(MY_PARTITION); + params.setServers(Arrays.asList(SERVER)); + return this; } } -- cgit 1.2.3-korg