This commit is contained in:
parent
a450b739d3
commit
03a06728bb
@ -41,6 +41,7 @@ class Glue {
|
|||||||
consume(inputQueueName) {
|
consume(inputQueueName) {
|
||||||
consumeMessageWithConfirm({
|
consumeMessageWithConfirm({
|
||||||
val rawJson = String(it.body)
|
val rawJson = String(it.body)
|
||||||
|
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)
|
||||||
outputChannel.basicPublish(mqOutputExchange,"", null, gson.toJson(outputObject).toByteArray())
|
outputChannel.basicPublish(mqOutputExchange,"", null, gson.toJson(outputObject).toByteArray())
|
||||||
|
Loading…
Reference in New Issue
Block a user