X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=sources%2Fhv-collector-xnf-simulator%2Fsrc%2Fmain%2Fkotlin%2Forg%2Fonap%2Fdcae%2Fcollectors%2Fveshv%2Fsimulators%2Fxnf%2Fimpl%2Fadapters%2FVesHvClient.kt;h=6e707c3a5923092357a716e95765ba64197fb229;hb=867f482cbb9241df483b815c16be01d9ff391f09;hp=75ff8955eba5ce2e86bdc20e6dea7557f0aa1fd3;hpb=e1c68f37ec3ba3ee512b86846a134d2f278b6571;p=dcaegen2%2Fcollectors%2Fhv-ves.git

diff --git a/sources/hv-collector-xnf-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/xnf/impl/adapters/VesHvClient.kt b/sources/hv-collector-xnf-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/xnf/impl/adapters/VesHvClient.kt
index 75ff8955..6e707c3a 100644
--- a/sources/hv-collector-xnf-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/xnf/impl/adapters/VesHvClient.kt
+++ b/sources/hv-collector-xnf-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/xnf/impl/adapters/VesHvClient.kt
@@ -35,6 +35,7 @@ import reactor.core.publisher.Mono
 import reactor.core.publisher.ReplayProcessor
 import reactor.netty.NettyOutbound
 import reactor.netty.tcp.TcpClient
+import reactor.util.concurrent.Queues.XS_BUFFER_SIZE
 
 /**
  * @author Jakub Dudycz <jakub.dudycz@nokia.com>
@@ -76,7 +77,7 @@ class VesHvClient(private val configuration: SimulatorConfiguration) {
         val encoder = WireFrameEncoder(allocator)
         val frames = messages
                 .map(encoder::encode)
-                .window(MAX_BATCH_SIZE)
+                .window(XS_BUFFER_SIZE)
 
         return nettyOutbound
                 .logConnectionClosed()
@@ -101,6 +102,5 @@ class VesHvClient(private val configuration: SimulatorConfiguration) {
 
     companion object {
         private val logger = Logger(VesHvClient::class)
-        private const val MAX_BATCH_SIZE = 128
     }
 }