tormakris/messagequeue-glue
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

use utf8
All checks were successful
continuous-integration/drone/push Build is passing
Details

Browse Source
This commit is contained in:
Torma Kristóf 2020-05-22 04:43:08 +02:00
parent fcb35bae01
commit bfc74ab575
Signed by: tormakris
GPG Key ID: DC83C4F2C41B1047
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/kotlin/consumer/GlueConsumer.kt
View File

@ -33,7 +33,7 @@ class GlueConsumer() : Consumer {
} }
override fun handleDelivery(consumerTag : String?, envelope : Envelope?, basicProperties : AMQP.BasicProperties?, body : ByteArray?) { 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) println(rawJson)
val probability = Random.nextDouble(0.0,1.0) val probability = Random.nextDouble(0.0,1.0)
val outputObject = OutputModel(tag=rawJson, probability=probability) val outputObject = OutputModel(tag=rawJson, probability=probability)