diff options
author | 2019-06-06 05:33:46 +0000 | |
---|---|---|
committer | 2019-06-06 05:33:46 +0000 | |
commit | c295544aa9e6cabb7ef63799cb5c98c599239a3a (patch) | |
tree | 2c12844e314a27ceef1d1d74f3af240dbafe03e0 /sources/hv-collector-main | |
parent | 7357386655e619ac7dfd5cf0d7801572513e2f4c (diff) | |
parent | 1ddd723f22c64dfb8c414fc8573ebe993ed00578 (diff) |
Merge "Support CBS request interval reconfiguration"
Diffstat (limited to 'sources/hv-collector-main')
-rw-r--r-- | sources/hv-collector-main/src/main/kotlin/org/onap/dcae/collectors/veshv/main/main.kt | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/sources/hv-collector-main/src/main/kotlin/org/onap/dcae/collectors/veshv/main/main.kt b/sources/hv-collector-main/src/main/kotlin/org/onap/dcae/collectors/veshv/main/main.kt index 123d2dc9..3dcb5ce1 100644 --- a/sources/hv-collector-main/src/main/kotlin/org/onap/dcae/collectors/veshv/main/main.kt +++ b/sources/hv-collector-main/src/main/kotlin/org/onap/dcae/collectors/veshv/main/main.kt @@ -42,7 +42,6 @@ private const val VES_HV_PACKAGE = "org.onap.dcae.collectors.veshv" private val logger = Logger("$VES_HV_PACKAGE.main") private val hvVesServer = AtomicReference<ServerHandle>() -private val configurationModule = ConfigurationModule() private val sslContextFactory = SslContextFactory() private val maxCloseTime = Duration.ofSeconds(10) @@ -52,10 +51,10 @@ fun main(args: Array<String>) { HealthState.INSTANCE.changeState(HealthDescription.RETRYING_FOR_DYNAMIC_CONFIGURATION) } } - + val configurationModule = ConfigurationModule(configStateListener) HealthCheckServer.start(configurationModule.healthCheckPort(args)).block() configurationModule - .hvVesConfigurationUpdates(args, configStateListener, ServiceContext::mdc) + .hvVesConfigurationUpdates(args, ServiceContext::mdc) .publishOn(Schedulers.single(Schedulers.elastic())) .doOnNext { logger.info(ServiceContext::mdc) { "Using updated configuration for new connections" } |