1 files changed, 4 insertions, 7 deletions
diff --git a/sources/hv-collector-ct/src/test/kotlin/org/onap/dcae/collectors/veshv/tests/component/Sut.kt b/sources/hv-collector-ct/src/test/kotlin/org/onap/dcae/collectors/veshv/tests/component/Sut.kt
index 8b2bc13c..88d1567e 100644
--- a/sources/hv-collector-ct/src/test/kotlin/org/onap/dcae/collectors/veshv/tests/component/Sut.kt
+++ b/sources/hv-collector-ct/src/test/kotlin/org/onap/dcae/collectors/veshv/tests/component/Sut.kt
@@ -55,8 +55,7 @@ class Sut(configuration: CollectorConfiguration, sink: Sink = StoringSink()) : C
     private val collectorProvider = HvVesCollectorFactory(
             configuration,
             sinkProvider,
-            metrics,
-            MAX_PAYLOAD_SIZE_BYTES
+            metrics
     )
 
     val collector: Collector
@@ -64,18 +63,18 @@ class Sut(configuration: CollectorConfiguration, sink: Sink = StoringSink()) : C
 
 
     fun handleConnection(sink: StoringSink, vararg packets: ByteBuf): List<RoutedMessage> {
-        collector.handleConnection(Flux.fromArray(packets)).block(timeout)
+        collector.handleConnection(Flux.fromArray(packets)).block(TIMEOUT)
         return sink.sentMessages
     }
 
     fun handleConnection(vararg packets: ByteBuf) {
-        collector.handleConnection(Flux.fromArray(packets)).block(timeout)
+        collector.handleConnection(Flux.fromArray(packets)).block(TIMEOUT)
     }
 
     override fun close() = collectorProvider.close()
 
     companion object {
-        const val MAX_PAYLOAD_SIZE_BYTES = 1024 * 1024
+        private val TIMEOUT = Duration.ofSeconds(10)
     }
 }
 
@@ -95,8 +94,6 @@ class DummySinkFactory(private val sink: Sink) : SinkFactory {
             }
 }
 
-private val timeout = Duration.ofSeconds(10)
-
 fun vesHvWithAlwaysSuccessfulSink(routing: Routing = basicRouting): Sut =
         Sut(CollectorConfiguration(routing), AlwaysSuccessfulSink())