diff options
Diffstat (limited to 'src/sch/core.clj')
| -rw-r--r-- | src/sch/core.clj | 10 |
1 files changed, 7 insertions, 3 deletions
diff --git a/src/sch/core.clj b/src/sch/core.clj index d83d266..1852c76 100644 --- a/src/sch/core.clj +++ b/src/sch/core.clj @@ -29,11 +29,12 @@ [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.openecomp.sdc.impl DistributionClientFactory) - (org.openecomp.sdc.api.consumer IConfiguration INotificationCallback + (:import (org.onap.sdc.impl DistributionClientFactory) + (org.onap.sdc.api.consumer IConfiguration INotificationCallback IDistributionStatusMessage) - (org.openecomp.sdc.utils DistributionActionResultEnum DistributionStatusEnum) + (org.onap.sdc.utils DistributionActionResultEnum DistributionStatusEnum) (com.google.gson Gson) ) (:gen-class)) @@ -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! |