From e9220923d2a13fa787f2f2f7b8bedc60cc9b2324 Mon Sep 17 00:00:00 2001 From: pbiniek Date: Wed, 27 Feb 2019 23:31:15 +0100 Subject: Added JSON config file format utils Change-Id: I97fdd72324495b4c838e44c306cbcacac6b11bc1 Signed-off-by: Pawel Biniek Issue-ID: DCAEGEN2-1323 --- .../main/kotlin/org/onap/dcae/collectors/veshv/model/routing.kt | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) (limited to 'sources/hv-collector-core') diff --git a/sources/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/model/routing.kt b/sources/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/model/routing.kt index ad97a3f7..dc7db5a2 100644 --- a/sources/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/model/routing.kt +++ b/sources/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/model/routing.kt @@ -29,7 +29,7 @@ data class Routing(val routes: List) { Option.fromNullable(routes.find { it.applies(commonHeader) }) } -data class Route(val domain: String, val targetTopic: String, val partitioning: (CommonEventHeader) -> Int) { +data class Route(val domain: String, val targetTopic: String, val partitioning: (CommonEventHeader) -> Int = {0}) { fun applies(commonHeader: CommonEventHeader) = commonHeader.domain == domain @@ -67,15 +67,15 @@ class RouteBuilder { private lateinit var targetTopic: String private lateinit var partitioning: (CommonEventHeader) -> Int - fun fromDomain(domain: String) { + fun fromDomain(domain: String) : RouteBuilder = apply { this.domain = domain } - fun toTopic(targetTopic: String) { + fun toTopic(targetTopic: String) : RouteBuilder = apply { this.targetTopic = targetTopic } - fun withFixedPartitioning(num: Int = 0) { + fun withFixedPartitioning(num: Int = 0) : RouteBuilder = apply { partitioning = { num } } -- cgit 1.2.3-korg