diff options
| author |   Piotr Jaszczyk <piotr.jaszczyk@nokia.com> | 2019-04-12 06:20:23 +0000 |
|---|---|---|
| committer |   Gerrit Code Review <gerrit@onap.org> | 2019-04-12 06:20:23 +0000 |
| commit | 24d0a4c08237dc95c7eca55122e9c305750ce248 (patch) | |
| tree | 7993bdfa2d7da01260823b4080598c2a778fab2c /sources/hv-collector-core | |
| parent | 6a7e8dce0126f355a0ef5663304825bea4c79a20 (diff) | |
| parent | ea33ac382e06d2f064d42aebd5b223a3de988b6a (diff) | |
Merge "Fix xnf-simulator message sending bug"
Diffstat (limited to 'sources/hv-collector-core')
| -rw-r--r-- | sources/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/impl/Router.kt | 10 |
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> = |