aboutsummaryrefslogtreecommitdiffstats
path: root/sources/hv-collector-core/src
diff options
context:
space:
mode:
authorJakub Dudycz <jakub.dudycz@nokia.com>2019-04-10 12:51:14 +0200
committerJakub Dudycz <jakub.dudycz@nokia.com>2019-04-11 11:01:27 +0000
commitea33ac382e06d2f064d42aebd5b223a3de988b6a (patch)
tree46f8dc222311883cd151c1cddf885a94a5851914 /sources/hv-collector-core/src
parentd52444107a3c62c1027e35178b76645ceb4d2c4e (diff)
Fix xnf-simulator message sending bug
Fix bug where xnf-simulator was failing to send messages with invalid wire frame. Generated events couldn't pass HV-VES client validatation, because they had empty payload. Change-Id: I20fb6254e432de096acfcfb8f0a0a5f912ca08c0 Signed-off-by: Jakub Dudycz <jakub.dudycz@nokia.com> Issue-ID: DCAEGEN2-1413
Diffstat (limited to 'sources/hv-collector-core/src')
-rw-r--r--sources/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/impl/Router.kt10
1 files changed, 3 insertions, 7 deletions
diff --git a/sources/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/impl/Router.kt b/sources/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/impl/Router.kt
index fe34a9c7..fec713ad 100644
--- a/sources/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/impl/Router.kt
+++ b/sources/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/impl/Router.kt
@@ -26,9 +26,9 @@ import org.onap.dcae.collectors.veshv.boundary.Sink
import org.onap.dcae.collectors.veshv.boundary.SinkFactory
import org.onap.dcae.collectors.veshv.config.api.model.Route
import org.onap.dcae.collectors.veshv.config.api.model.Routing
-import org.onap.dcae.collectors.veshv.model.ClientContext
import org.onap.dcae.collectors.veshv.domain.RoutedMessage
import org.onap.dcae.collectors.veshv.domain.VesMessage
+import org.onap.dcae.collectors.veshv.model.ClientContext
import org.onap.dcae.collectors.veshv.model.ConsumedMessage
import org.onap.dcae.collectors.veshv.model.MessageDropCause
import org.onap.dcae.collectors.veshv.utils.logging.Logger
@@ -43,12 +43,8 @@ class Router internal constructor(private val routing: Routing,
sinkFactory: SinkFactory,
ctx: ClientContext,
metrics: Metrics) :
- this(routing,
- constructMessageSinks(routing, sinkFactory, ctx),
- ctx,
- metrics) {
- logger.debug(ctx::mdc) { "Routing for client: $routing" }
- logger.trace(ctx::mdc) { "Message sinks configured for client: $messageSinks" }
+ this(routing, constructMessageSinks(routing, sinkFactory, ctx), ctx, metrics) {
+ logger.debug(ctx::mdc) { "Routing configuration for client: $routing" }
}
fun route(message: VesMessage): Flux<ConsumedMessage> =