diff options
| author |   Piotr Jaszczyk <piotr.jaszczyk@nokia.com> | 2019-04-10 09:31:15 +0000 |
|---|---|---|
| committer |   Gerrit Code Review <gerrit@onap.org> | 2019-04-10 09:31:15 +0000 |
| commit | d52444107a3c62c1027e35178b76645ceb4d2c4e (patch) | |
| tree | d0dbd57bc0f5a6e4387e74f1c00912ab8f2f98ee /sources/hv-collector-core/src | |
| parent | f864f9ae0cf8cef72b64cbda8964e86398b3f749 (diff) | |
| parent | 735469d5003388df3622819c3d1db0e89a64197c (diff) | |
Merge "Move maxPayloadSizeBytes to CollectorConfiguration"
Diffstat (limited to 'sources/hv-collector-core/src')
| -rw-r--r-- | sources/hv-collector-core/src/main/kotlin/org/onap/dcae/collectors/veshv/factory/HvVesCollectorFactory.kt | 7 |
1 files changed, 4 insertions, 3 deletions
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) |