gerrit.onap Code Review - dcaegen2/collectors/hv-ves.git/commit

Code Review / dcaegen2 / collectors / hv-ves.git / commit

author	Piotr Jaszczyk <piotr.jaszczyk@nokia.com>
	Tue, 22 Jan 2019 10:43:18 +0000 (11:43 +0100)
committer	Piotr Jaszczyk <piotr.jaszczyk@nokia.com>
	Tue, 22 Jan 2019 13:30:32 +0000 (14:30 +0100)
commit	d7532776b9d608632b91a6c658fcd72ca7c70d64
tree	0d90d7a75a4a1d83dd1cbd7c5af43e71bb6fea6c	tree \| snapshot
parent	4c529a33439cc40bf192ea3f8dac57d189d60b9f	commit \| diff

Close KafkaSender when handling SIGINT

Closing KafkaSender should result in flushing any pending messages.

Change-Id: Ib251f5ca3527266831189df542784cc17173d8dc
Issue-ID: DCAEGEN2-1065
Signed-off-by: Piotr Jaszczyk <piotr.jaszczyk@nokia.com>

18 files changed:

sources/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/boundary/adapters.kt		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/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/model/ServiceContext.kt		diff \| blob \| history
sources/hv-collector-core/src/test/kotlin/org/onap/dcae/collectors/veshv/impl/adapters/kafka/KafkaSinkProviderTest.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-health-check/src/main/kotlin/org/onap/dcae/collectors/veshv/healthcheck/factory/HealthCheckApiServer.kt		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/ServerStarter.kt		diff \| blob \| history
sources/hv-collector-main/src/main/resources/logback.xml		diff \| blob \| history
sources/hv-collector-utils/pom.xml		diff \| blob \| history
sources/hv-collector-utils/src/main/kotlin/org/onap/dcae/collectors/veshv/utils/Closeable.kt	[new file with mode: 0644]	blob
sources/hv-collector-utils/src/main/kotlin/org/onap/dcae/collectors/veshv/utils/arrow/effects.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

RSS Atom