summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorIzabela Zawadzka <izabela.zawadzka@nokia.com>2019-03-29 14:10:07 +0100
committerIzabela Zawadzka <izabela.zawadzka@nokia.com>2019-03-29 14:13:00 +0100
commitbf318abbdccd73ff8df65eba777d94be66082e54 (patch)
tree7d599351c1bf9d3e53d85651fcef967b0e5cd55a
parent4281a12d8e892f46f5f2226ee0f8aee8b862b177 (diff)
Fix subscription error in DcaeAppSimulator
Change-Id: I6548d7e6c676498988ddcdde4331385e87ee746d Signed-off-by: Izabela Zawadzka <izabela.zawadzka@nokia.com> Issue-ID: DCAEGEN2-1372
-rw-r--r--sources/hv-collector-dcae-app-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/dcaeapp/impl/adapters/KafkaSource.kt2
1 files changed, 1 insertions, 1 deletions
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 {