diff options
| author |   Michael Hwang <mhwang@research.att.com> | 2018-04-05 14:20:44 -0400 |
|---|---|---|
| committer | Michael Hwang <mhwang@research.att.com> | 2018-04-05 14:25:25 -0400 |
| commit | d73e0d5ba6a2b3968f57cf474832c6e32fa683bf (patch) | |
| tree | 4a340054a8447caa9f7ccfac3afc4677748838b0 /src/sch | |
| parent | 97b39b1577063aea01bf35abb849503626164ce0 (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.clj | 4 |
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! |