Fix consul configuration delay

Delay configuration received from consul instead of default one

Change-Id: I09ec1a1e0d4a8334f83c054e0891b55ff8d049db
Issue-Id: ONAP-519
Signed-off-by: jdudycz@nokia.com
Issue-ID: DCAEGEN2-601

diff --git a/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/impl/adapters/ConsulConfigurationProvider.kt b/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/impl/adapters/ConsulConfigurationProvider.kt
index 727f025..786bc7c 100644 (file)
--- a/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/impl/adapters/ConsulConfigurationProvider.kt
+++ b/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/impl/adapters/ConsulConfigurationProvider.kt
@@ -64,7 +64,7 @@ internal class ConsulConfigurationProvider(private val url: String,
                             withFixedPartitioning()
                         }
                     }.build())
-    ).doOnNext { logger.info("Applied default configuration") }.delayElement(firstRequestDelay)
+    ).doOnNext { logger.info("Applied default configuration") }
 
     private fun createConsulFlux(): Flux<CollectorConfiguration> =
             http.get(url, mapOf(Pair("index", lastModifyIndex.get())))
@@ -79,6 +79,7 @@ internal class ConsulConfigurationProvider(private val url: String,
                     .map(::decodeConfiguration)
                     .map(::createCollectorConfiguration)
                     .repeat()
+                    .delaySubscription(firstRequestDelay)
 
     private fun parseJsonResponse(responseString: String): JsonObject =
             Json.createReader(StringReader(responseString)).readArray().first().asJsonObject()