aboutsummaryrefslogtreecommitdiffstats
path: root/src
diff options
context:
space:
mode:
authorMichael Hwang <mhwang@research.att.com>2017-10-10 16:24:20 -0400
committerMichael Hwang <mhwang@research.att.com>2017-10-11 11:52:51 -0400
commit366286371bfa76884b163e84928c31d6a4776439 (patch)
tree1a2ba6f000a82a54e2eb9c05ffcf35c6b93d82dd /src
parent983e821479b600fc8288534c8d910d85f52dde18 (diff)
Use the latest distribution client
Also address Docker build issue Issue-Id: DCAEGEN2-150 Change-Id: I2db297eed1c9c1c97cc440703cf4309fae8e8906 Signed-off-by: Michael Hwang <mhwang@research.att.com>
Diffstat (limited to 'src')
-rw-r--r--src/sch/asdc_client.clj2
-rw-r--r--src/sch/core.clj25
2 files changed, 14 insertions, 13 deletions
diff --git a/src/sch/asdc_client.clj b/src/sch/asdc_client.clj
index 702c571..a9742b3 100644
--- a/src/sch/asdc_client.clj
+++ b/src/sch/asdc_client.clj
@@ -44,7 +44,7 @@
(defn construct-service-path
[service-uuid]
- (str "/asdc/v1/catalog/services/" service-uuid "/metadata"))
+ (str "/sdc/v1/catalog/services/" service-uuid "/metadata"))
(defn get-artifact!
diff --git a/src/sch/core.clj b/src/sch/core.clj
index 8684576..a5e1998 100644
--- a/src/sch/core.clj
+++ b/src/sch/core.clj
@@ -92,24 +92,25 @@
[config]
(let [config-asdc (:asdcDistributionClient config)]
(proxy [IConfiguration] []
- (getAsdcAddress [] (:asdcAddress config-asdc))
- (getUser [] (:user config-asdc))
- (getPassword [] (:password config-asdc))
- (getPollingInterval [] (:pollingInterval config-asdc))
- (getPollingTimeout [] (:pollingTimeout config-asdc))
+ (getAsdcAddress [] (str (:asdcAddress config-asdc)))
+ (getUser [] (str (:user config-asdc)))
+ (getPassword [] (str (:password config-asdc)))
+ (getPollingInterval [] (int (:pollingInterval config-asdc)))
+ (getPollingTimeout [] (int (:pollingTimeout config-asdc)))
; Note: The following didn't work
; (. Arrays asList (. ArtifactTypeEnum values))
; Also, cannot just use a narrow list of artifact types in order
; to handle the deletion scenario.
(getRelevantArtifactTypes [] (java.util.ArrayList.
(get-dcae-artifact-types)))
- (getConsumerGroup [] (:consumerGroup config-asdc))
- (getConsumerID [] (:consumerId config-asdc))
- (getEnvironmentName [] (:environmentName config-asdc))
- (getKeyStorePath [] (:keyStorePath config-asdc))
- (getKeyStorePassword [] (:keyStorePassword config-asdc))
- (activateServerTLSAuth [] (:activateServerTLSAuth config-asdc))
- (isFilterInEmptyResources [] (:isFilterInEmptyResources config-asdc))
+ (getConsumerGroup [] (str (:consumerGroup config-asdc)))
+ (getConsumerID [] (str (:consumerId config-asdc)))
+ (getEnvironmentName [] (str (:environmentName config-asdc)))
+ (getKeyStorePath [] (str (:keyStorePath config-asdc)))
+ (getKeyStorePassword [] (str (:keyStorePassword config-asdc)))
+ (activateServerTLSAuth [] (boolean (:activateServerTLSAuth config-asdc)))
+ (isFilterInEmptyResources [] (boolean (:isFilterInEmptyResources config-asdc)))
+ (isUseHttpsWithDmaap [] (contains? config-asdc :useHttpsWithDmaap) (Boolean/valueOf(str (:useHttpsWithDmaap config-asdc))) true)
)))
(defn run-distribution-client!