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())