diff options
Diffstat (limited to 'sources/hv-collector-core')
-rw-r--r-- | sources/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/model/routing.kt | 8 |
1 files changed, 4 insertions, 4 deletions
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<Route>) { 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 } } |