From: Izabela Zawadzka <izabela.zawadzka@nokia.com>
Date: Fri, 29 Mar 2019 13:10:07 +0000 (+0100)
Subject: Fix subscription error in DcaeAppSimulator
X-Git-Tag: 1.1.0~24
X-Git-Url: https://gerrit.onap.org/r/gitweb?a=commitdiff_plain;h=bf318abbdccd73ff8df65eba777d94be66082e54;p=dcaegen2%2Fcollectors%2Fhv-ves.git

Fix subscription error in DcaeAppSimulator

Change-Id: I6548d7e6c676498988ddcdde4331385e87ee746d
Signed-off-by: Izabela Zawadzka <izabela.zawadzka@nokia.com>
Issue-ID: DCAEGEN2-1372
---

diff --git a/sources/hv-collector-dcae-app-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/dcaeapp/impl/adapters/KafkaSource.kt b/sources/hv-collector-dcae-app-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/dcaeapp/impl/adapters/KafkaSource.kt
index 7bab9676..3314805e 100644
--- a/sources/hv-collector-dcae-app-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/dcaeapp/impl/adapters/KafkaSource.kt
+++ b/sources/hv-collector-dcae-app-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/dcaeapp/impl/adapters/KafkaSource.kt
@@ -34,7 +34,7 @@ class KafkaSource(private val receiver: KafkaReceiver<ByteArray, ByteArray>) {
 
     fun start() = Consumer()
             .also { consumer ->
-                receiver.receive().map(consumer::update)
+                receiver.receive().map(consumer::update).subscribe()
             }
 
     companion object {