From 735469d5003388df3622819c3d1db0e89a64197c Mon Sep 17 00:00:00 2001 From: Jakub Dudycz Date: Mon, 8 Apr 2019 14:09:16 +0200 Subject: Move maxPayloadSizeBytes to CollectorConfiguration Signed-off-by: Jakub Dudycz Issue-ID: DCAEGEN2-1387 Change-Id: I37151a58f5244841243dc531912af2ef50ea5d3c --- .../onap/dcae/collectors/veshv/factory/HvVesCollectorFactory.kt | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) (limited to 'sources/hv-collector-core/src') diff --git a/sources/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/factory/HvVesCollectorFactory.kt b/sources/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/factory/HvVesCollectorFactory.kt index 3524f14c..c3c5d733 100644 --- a/sources/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/factory/HvVesCollectorFactory.kt +++ b/sources/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/factory/HvVesCollectorFactory.kt @@ -37,8 +37,7 @@ import org.onap.dcae.collectors.veshv.model.ClientContext */ class HvVesCollectorFactory(private val configuration: CollectorConfiguration, private val sinkFactory: SinkFactory, - private val metrics: Metrics, - private val maxPayloadSizeBytes: Int): CollectorFactory { + private val metrics: Metrics) : CollectorFactory { override fun invoke(ctx: ClientContext): Collector = createVesHvCollector(ctx) @@ -48,7 +47,9 @@ class HvVesCollectorFactory(private val configuration: CollectorConfiguration, private fun createVesHvCollector(ctx: ClientContext): Collector = HvVesCollector( clientContext = ctx, - wireChunkDecoder = WireChunkDecoder(WireFrameDecoder(maxPayloadSizeBytes), ctx), + wireChunkDecoder = WireChunkDecoder( + WireFrameDecoder(configuration.maxPayloadSizeBytes), ctx + ), protobufDecoder = VesDecoder(), router = Router(configuration.routing, sinkFactory, ctx, metrics), metrics = metrics) -- cgit 1.2.3-korg