VESEvent payload generation introduction

[dcaegen2/collectors/hv-ves.git] / hv-collector-client-simulator / src / main / kotlin / org / onap / dcae / collectors / veshv / simulators / xnf / impl / HttpServer.kt

diff --git a/hv-collector-client-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/xnf/impl/HttpServer.kt b/hv-collector-client-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/xnf/impl/HttpServer.kt
index bc1cff7..bc7db86 100644 (file)
--- a/hv-collector-client-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/xnf/impl/HttpServer.kt
+++ b/hv-collector-client-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/xnf/impl/HttpServer.kt
@@ -47,7 +47,7 @@ class HttpServer(private val vesClient: VesHvClient) {
             ctx.request.body
                     .map { Json.createReader(it.inputStream).readObject() }
                     .map { extractMessageParameters(it) }
-                    .map { MessageFactory.createMessageFlux(it) }
+                    .map { MessageFactory.INSTANCE.createMessageFlux(it) }
                     .onError { handleException(it, ctx) }
                     .then {
                         vesClient.send(it)
@@ -75,7 +75,7 @@ class HttpServer(private val vesClient: VesHvClient) {
 
     private fun extractMessageParameters(request: JsonObject): MessageParameters =
             try {
-                val commonEventHeader = MessageFactory
+                val commonEventHeader = MessageFactory.INSTANCE
                         .parseCommonHeader(request.getJsonObject("commonEventHeader"))
                 val messagesAmount = request.getJsonNumber("messagesAmount").longValue()
                 MessageParameters(commonEventHeader, messagesAmount)