diff options
author | Krishnajinka <kris.jinka@samsung.com> | 2018-08-14 09:26:00 +0900 |
---|---|---|
committer | Krishnajinka <kris.jinka@samsung.com> | 2018-08-14 09:26:50 +0900 |
commit | d40823cd9dc76fee6d77963902fd786222ba15a6 (patch) | |
tree | d7ee80a548b85578b8461be139db177a1c0972c0 /policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal | |
parent | 2d381afcd78b61d8791ace22b676e88271b3bdce (diff) |
Modify topic factory to use builder param
Fix sonar issue with method build using more than 7 params
Use BusTopicParams to send parameters into methods
Issue-ID: POLICY-1017
Change-Id: I194284da63cb95f91ce2e8a8c21a526a5ab9f6f3
Signed-off-by: Krishnajinka <kris.jinka@samsung.com>
Diffstat (limited to 'policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal')
-rw-r--r-- | policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/BusTopicParams.java | 47 |
1 files changed, 28 insertions, 19 deletions
diff --git a/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/BusTopicParams.java b/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/BusTopicParams.java index f9eca081..347ae42c 100644 --- a/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/BusTopicParams.java +++ b/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/BusTopicParams.java @@ -69,80 +69,81 @@ public class BusTopicParams { private String longitude; private Map<String, String> additionalProps; private String partitionId; + private boolean managed; - String getPartitionId() { + public String getPartitionId() { return partitionId; } - String getUserName() { + public String getUserName() { return userName; } - String getPassword() { + public String getPassword() { return password; } - String getEnvironment() { + public String getEnvironment() { return environment; } - String getAftEnvironment() { + public String getAftEnvironment() { return aftEnvironment; } - String getPartner() { + public String getPartner() { return partner; } - String getLatitude() { + public String getLatitude() { return latitude; } - String getLongitude() { + public String getLongitude() { return longitude; } - Map<String, String> getAdditionalProps() { + public Map<String, String> getAdditionalProps() { return additionalProps; } - List<String> getServers() { + public List<String> getServers() { return servers; } - String getTopic() { + public String getTopic() { return topic; } - String getApiKey() { + public String getApiKey() { return apiKey; } - String getApiSecret() { + public String getApiSecret() { return apiSecret; } - String getConsumerGroup() { + public String getConsumerGroup() { return consumerGroup; } - String getConsumerInstance() { + public String getConsumerInstance() { return consumerInstance; } - int getFetchTimeout() { + public int getFetchTimeout() { return fetchTimeout; } - int getFetchLimit() { + public int getFetchLimit() { return fetchLimit; } - boolean isUseHttps() { + public boolean isUseHttps() { return useHttps; } - boolean isAllowSelfSignedCerts() { + public boolean isAllowSelfSignedCerts() { return allowSelfSignedCerts; } @@ -207,6 +208,10 @@ public class BusTopicParams { return (partitionId == null || partitionId.trim().isEmpty()); } + public boolean isManaged() { + return managed; + } + public static class TopicParamsBuilder { BusTopicParams m = new BusTopicParams(); @@ -312,6 +317,10 @@ public class BusTopicParams { return m; } + public TopicParamsBuilder managed(boolean managed) { + this.m.managed = managed; + return this; + } } } |