Apply builder pattern for topic cnsmer prdcr

Modify endpoints event bus related classes to use builder pattern
in particular apply bus topic params object instead of
using parameters as it is. Rework based on commnts

Issue-ID: POLICY-1017
Change-Id: I572a72fa525cf4f664eb70d0415be73116499bd2
Signed-off-by: krisjinka <kris.jinka@samsung.com>

1 files changed, 14 insertions, 12 deletions

diff --git a/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/InlineBusTopicSink.java b/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/InlineBusTopicSink.java
index f3c736da..5493468a 100644
--- a/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/InlineBusTopicSink.java
+++ b/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/InlineBusTopicSink.java
@@ -3,6 +3,7 @@
  * policy-endpoints
  * ================================================================================
  * Copyright (C) 2017-2018 AT&T Intellectual Property. All rights reserved.
+ * Modified Copyright (C) 2018 Samsung Electronics Co., Ltd.
  * ================================================================================
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -52,23 +53,24 @@ public abstract class InlineBusTopicSink extends BusTopicBase implements BusTopi
 
     /**
      * constructor for abstract sink
-     * 
-     * @param servers servers
-     * @param topic topic
-     * @param apiKey api secret
-     * @param apiSecret api secret
-     * @param partitionId partition id
-     * @param useHttps does connection use HTTPS?
-     * @param allowSelfSignedCerts are self-signed certificates allow
+     * @param busTopicParams contains below listed attributes
+     * servers servers
+     * topic topic
+     * apiKey api secret
+     * apiSecret api secret
+     * partitionId partition id
+     * useHttps does connection use HTTPS?
+     * allowSelfSignedCerts are self-signed certificates allow     *
      * @throws IllegalArgumentException in invalid parameters are passed in
      */
-    public InlineBusTopicSink(List<String> servers, String topic, String apiKey, String apiSecret, String partitionId,
-            boolean useHttps, boolean allowSelfSignedCerts) {
+    public InlineBusTopicSink(BusTopicParams busTopicParams) {
 
-        super(servers, topic, apiKey, apiSecret, useHttps, allowSelfSignedCerts);
+        super(busTopicParams);
 
-        if (partitionId == null || partitionId.isEmpty()) {
+        if (busTopicParams.isPartitionIdNullOrEmpty()) {
             this.partitionId = UUID.randomUUID().toString();
+        } else {
+            this.partitionId = busTopicParams.getPartitionId();
         }
     }