summaryrefslogtreecommitdiffstats
path: root/sources/hv-collector-main
diff options
context:
space:
mode:
authorkjaniak <kornel.janiak@nokia.com>2019-05-22 22:19:49 +0200
committerkjaniak <kornel.janiak@nokia.com>2019-06-05 16:01:22 +0200
commit1ddd723f22c64dfb8c414fc8573ebe993ed00578 (patch)
tree278aa739a0642cb40c358ffdf8f2e3d2e313425d /sources/hv-collector-main
parentdc936d27d761bde31ac5916a84efa2f48ec32b83 (diff)
Support CBS request interval reconfiguration
Change-Id: Ie8892e33b2f6a58d6076f66e6cc6a2df830dfa48 Issue-ID: DCAEGEN2-1525 Signed-off-by: kjaniak <kornel.janiak@nokia.com>
Diffstat (limited to 'sources/hv-collector-main')
-rw-r--r--sources/hv-collector-main/src/main/kotlin/org/onap/dcae/collectors/veshv/main/main.kt5
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" }