From 03a06728bb33d803b8d0b6d095fb694e37201273 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Torma=20Krist=C3=B3f?= Date: Fri, 22 May 2020 03:37:11 +0200 Subject: [PATCH] add some logging --- src/main/kotlin/worker/Glue.kt | 1 + 1 file changed, 1 insertion(+) diff --git a/src/main/kotlin/worker/Glue.kt b/src/main/kotlin/worker/Glue.kt index cc066b5..98c50bb 100644 --- a/src/main/kotlin/worker/Glue.kt +++ b/src/main/kotlin/worker/Glue.kt @@ -41,6 +41,7 @@ class Glue { consume(inputQueueName) { consumeMessageWithConfirm({ val rawJson = String(it.body) + println(rawJson) val probability = Random.nextDouble(0.0,1.0) val outputObject = OutputModel(tag=rawJson, probability=probability) outputChannel.basicPublish(mqOutputExchange,"", null, gson.toJson(outputObject).toByteArray())