Code Review / dcaegen2 / collectors / hv-ves.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: 6a00e38) | patch
Fix shutting down when new config received bug 77/83977/5
authorPiotr Jaszczyk <piotr.jaszczyk@nokia.com>
Tue, 2 Apr 2019 13:40:46 +0000 (15:40 +0200)
committerPiotr Jaszczyk <piotr.jaszczyk@nokia.com>
Wed, 3 Apr 2019 06:51:03 +0000 (08:51 +0200)
commit302d27926c76bb99eecc4f74d333d0e8ff240c6e
treec9b716c649deb8b14d9ace320b3f35ed22604d0etree | snapshot
parent6a00e38550fd1745c3377da2099bf5a615f69053commit | diff
Fix shutting down when new config received bug

When new configuration has been received and at least one client
connection has been active the collector used to shut down.

Also got rid of some more IO monad usage.

Change-Id: I7981ff388ff1264a79d722727ef3005cf39e9f0d
Issue-ID: DCAEGEN2-1382
Signed-off-by: Piotr Jaszczyk <piotr.jaszczyk@nokia.com>
21 files changed:
development/configuration/local.json [new file with mode: 0644] blob
sources/hv-collector-commandline/pom.xml diff | blob | history
sources/hv-collector-core/pom.xml diff | blob | history
sources/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/boundary/api.kt diff | blob | history
sources/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/factory/CollectorFactory.kt diff | blob | history
sources/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/impl/HvVesCollector.kt [moved from sources/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/impl/VesHvCollector.kt with 98% similarity] diff | blob | history
sources/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/impl/Router.kt diff | blob | history
sources/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/impl/adapters/kafka/KafkaPublisher.kt diff | blob | history
sources/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/impl/adapters/kafka/KafkaSinkProvider.kt diff | blob | history
sources/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/impl/socket/NettyTcpServer.kt diff | blob | history
sources/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/impl/wire/WireChunkDecoder.kt diff | blob | history
sources/hv-collector-ct/src/test/kotlin/org/onap/dcae/collectors/veshv/tests/component/Sut.kt diff | blob | history
sources/hv-collector-ct/src/test/kotlin/org/onap/dcae/collectors/veshv/tests/component/VesHvSpecification.kt diff | blob | history
sources/hv-collector-ct/src/test/kotlin/org/onap/dcae/collectors/veshv/tests/fakes/sink.kt diff | blob | history
sources/hv-collector-main/pom.xml diff | blob | history
sources/hv-collector-main/src/main/kotlin/org/onap/dcae/collectors/veshv/main/main.kt diff | blob | history
sources/hv-collector-main/src/main/kotlin/org/onap/dcae/collectors/veshv/main/servers/VesServer.kt diff | blob | history
sources/hv-collector-main/src/main/resources/logback.xml diff | blob | history
sources/hv-collector-main/src/test/kotlin/org/onap/dcae/collectors/veshv/main/MainTest.kt diff | blob | history
sources/hv-collector-utils/src/main/kotlin/org/onap/dcae/collectors/veshv/utils/Closeable.kt diff | blob | history
sources/hv-collector-utils/src/main/kotlin/org/onap/dcae/collectors/veshv/utils/server_handle.kt diff | blob | history
High Volume VES Collector