diff options
Diffstat (limited to 'src/sch')
| -rw-r--r-- | src/sch/core.clj | 10 | ||||
| -rw-r--r-- | src/sch/handle.clj | 2 | ||||
| -rw-r--r-- | src/sch/parse.clj | 2 |
3 files changed, 9 insertions, 5 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! diff --git a/src/sch/handle.clj b/src/sch/handle.clj index 13201c4..453b586 100644 --- a/src/sch/handle.clj +++ b/src/sch/handle.clj @@ -27,7 +27,7 @@ [sch.parse :refer [generate-dcae-service-type-requests get-service-locations]] ) - (:import (org.openecomp.sdc.utils DistributionStatusEnum)) + (:import (org.onap.sdc.utils DistributionStatusEnum)) (:gen-class)) diff --git a/src/sch/parse.clj b/src/sch/parse.clj index 7ce48e6..668dbf4 100644 --- a/src/sch/parse.clj +++ b/src/sch/parse.clj @@ -24,7 +24,7 @@ [sch.asdc-client :refer [construct-service-path]] [cheshire.core :refer [parse-string]] ) - (:import (org.openecomp.sdc.utils ArtifactTypeEnum)) + (:import (org.onap.sdc.utils ArtifactTypeEnum)) (:gen-class)) |