diff options
| author |   Izabela Zawadzka <izabela.zawadzka@nokia.com> | 2019-03-29 14:10:07 +0100 |
|---|---|---|
| committer | Izabela Zawadzka <izabela.zawadzka@nokia.com> | 2019-03-29 14:13:00 +0100 |
| commit | bf318abbdccd73ff8df65eba777d94be66082e54 (patch) | |
| tree | 7d599351c1bf9d3e53d85651fcef967b0e5cd55a /sources/hv-collector-dcae-app-simulator/src | |
| parent | 4281a12d8e892f46f5f2226ee0f8aee8b862b177 (diff) | |
Fix subscription error in DcaeAppSimulator
Change-Id: I6548d7e6c676498988ddcdde4331385e87ee746d
Signed-off-by: Izabela Zawadzka <izabela.zawadzka@nokia.com>
Issue-ID: DCAEGEN2-1372
Diffstat (limited to 'sources/hv-collector-dcae-app-simulator/src')
| -rw-r--r-- | sources/hv-collector-dcae-app-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/dcaeapp/impl/adapters/KafkaSource.kt | 2 |
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 { |