aboutsummaryrefslogtreecommitdiffstats
path: root/src/sch
diff options
context:
space:
mode:
authorMichael Hwang <mhwang@research.att.com>2018-04-05 14:20:44 -0400
committerMichael Hwang <mhwang@research.att.com>2018-04-05 14:25:25 -0400
commitd73e0d5ba6a2b3968f57cf474832c6e32fa683bf (patch)
tree4a340054a8447caa9f7ccfac3afc4677748838b0 /src/sch
parent97b39b1577063aea01bf35abb849503626164ce0 (diff)
Update IConfiguration impl
v1.3.0 of distribution client changed the IConfiguration interface Change-Id: I29164aea59cdfd1273f1b7652d828d62d804b5f5 Issue-ID: DCAEGEN2-431 Signed-off-by: Michael Hwang <mhwang@research.att.com>
Diffstat (limited to 'src/sch')
-rw-r--r--src/sch/core.clj4
1 files changed, 4 insertions, 0 deletions
diff --git a/src/sch/core.clj b/src/sch/core.clj
index a1734fa..1852c76 100644
--- a/src/sch/core.clj
+++ b/src/sch/core.clj
@@ -29,6 +29,7 @@
[sch.inventory-client :refer [create-inventory-conn]]
[sch.parse :refer [get-dcae-artifact-types pick-out-artifact]]
[sch.util :refer [read-config]]
+ [clojure.string :as strlib]
)
(:import (org.onap.sdc.impl DistributionClientFactory)
(org.onap.sdc.api.consumer IConfiguration INotificationCallback
@@ -93,6 +94,8 @@
(let [config-asdc (:asdcDistributionClient config)]
(proxy [IConfiguration] []
(getAsdcAddress [] (str (:asdcAddress config-asdc)))
+ (getMsgBusAddress [] (java.util.ArrayList.
+ (strlib/split (str (:msgBusAddress config-asdc)) #",")))
(getUser [] (str (:user config-asdc)))
(getPassword [] (str (:password config-asdc)))
(getPollingInterval [] (int (:pollingInterval config-asdc)))
@@ -111,6 +114,7 @@
(activateServerTLSAuth [] (boolean (:activateServerTLSAuth config-asdc)))
(isFilterInEmptyResources [] (boolean (:isFilterInEmptyResources config-asdc)))
(isUseHttpsWithDmaap [] (boolean (:useHttpsWithDmaap config-asdc false)))
+ (isConsumeProduceStatusTopic [] (boolean (:isConsumeProduceStatusTopic config-asdc false)))
)))
(defn run-distribution-client!