diff options
author | kurczews <krzysztof.kurczewski@nokia.com> | 2019-06-03 11:31:43 +0200 |
---|---|---|
committer | kurczews <krzysztof.kurczewski@nokia.com> | 2019-06-03 11:34:58 +0200 |
commit | ae956fcb64d6d36ccc2e892984fd7d2c194e3b87 (patch) | |
tree | fc392cf3ef96ce57555d23ed4a38cd095e5572f7 /prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/configuration/CbsConfiguration.java | |
parent | 20c84fd46a3cf1ffa2e07e740cdccc3c1b77c13c (diff) |
Adjust PRH with SDK
Change-Id: If1f230047bf635d5288482b275d05c484a4ecaec
Issue-ID: DCAEGEN2-1521
Signed-off-by: kurczews <krzysztof.kurczewski@nokia.com>
Diffstat (limited to 'prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/configuration/CbsConfiguration.java')
-rw-r--r-- | prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/configuration/CbsConfiguration.java | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/configuration/CbsConfiguration.java b/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/configuration/CbsConfiguration.java index 3f018b53..e262da55 100644 --- a/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/configuration/CbsConfiguration.java +++ b/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/configuration/CbsConfiguration.java @@ -24,7 +24,7 @@ import com.google.gson.JsonObject; import org.onap.dcaegen2.services.sdk.rest.services.aai.client.config.AaiClientConfiguration; import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.api.CbsClientFactory; import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.api.CbsRequests; -import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.EnvProperties; +import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.CbsClientConfiguration; import org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.api.DmaapClientFactory; import org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.api.MessageRouterPublisher; import org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.api.MessageRouterSubscriber; @@ -58,23 +58,23 @@ public class CbsConfiguration implements Config { } public void runTask() { - Flux.defer(this::resolveEnvProperties) + Flux.defer(this::resolveCbsClientConfiguration) .subscribeOn(Schedulers.parallel()) .subscribe(this::parsingConfigSuccess, this::parsingConfigError); } - private Mono<EnvProperties> resolveEnvProperties() { + private Mono<CbsClientConfiguration> resolveCbsClientConfiguration() { try { - return Mono.just(EnvProperties.fromEnvironment()); + return Mono.just(CbsClientConfiguration.fromEnvironment()); } catch(Exception e){ parsingConfigError(e); return consulConfigFileReader.evaluate(); } } - private void parsingConfigSuccess(EnvProperties envProperties) { + private void parsingConfigSuccess(CbsClientConfiguration cbsClientConfiguration) { LOGGER.debug("Fetching PRH configuration from Consul"); - CbsClientFactory.createCbsClient(envProperties) + CbsClientFactory.createCbsClient(cbsClientConfiguration) .flatMap(cbsClient -> cbsClient.get(CbsRequests.getAll(RequestDiagnosticContext.create()))) .subscribe(this::parseCBSConfig, this::cbsConfigError); } |