From bf318abbdccd73ff8df65eba777d94be66082e54 Mon Sep 17 00:00:00 2001 From: Izabela Zawadzka Date: Fri, 29 Mar 2019 14:10:07 +0100 Subject: Fix subscription error in DcaeAppSimulator Change-Id: I6548d7e6c676498988ddcdde4331385e87ee746d Signed-off-by: Izabela Zawadzka Issue-ID: DCAEGEN2-1372 --- .../collectors/veshv/simulators/dcaeapp/impl/adapters/KafkaSource.kt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'sources/hv-collector-dcae-app-simulator') 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) { fun start() = Consumer() .also { consumer -> - receiver.receive().map(consumer::update) + receiver.receive().map(consumer::update).subscribe() } companion object { -- cgit 1.2.3-korg