From bfc74ab5758677234a7813f60a26b5804e67dfa2 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Torma=20Krist=C3=B3f?= Date: Fri, 22 May 2020 04:43:08 +0200 Subject: [PATCH] use utf8 --- src/main/kotlin/consumer/GlueConsumer.kt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/kotlin/consumer/GlueConsumer.kt b/src/main/kotlin/consumer/GlueConsumer.kt index f87defd..93f6ae3 100644 --- a/src/main/kotlin/consumer/GlueConsumer.kt +++ b/src/main/kotlin/consumer/GlueConsumer.kt @@ -33,7 +33,7 @@ class GlueConsumer() : Consumer { } override fun handleDelivery(consumerTag : String?, envelope : Envelope?, basicProperties : AMQP.BasicProperties?, body : ByteArray?) { - val rawJson = body!!.toString() + val rawJson = body!!.toString(Charsets.UTF_8) println(rawJson) val probability = Random.nextDouble(0.0,1.0) val outputObject = OutputModel(tag=rawJson, probability=probability)