queue name

2020-05-22 04:34:51 +02:00 · 2020-05-22 04:34:51 +02:00 · fcb35bae01
commit fcb35bae01
parent d77b1508a3
1 changed files with 1 additions and 1 deletions
--- a/src/main/kotlin/worker/Glue.kt
+++ b/src/main/kotlin/worker/Glue.kt
@ -21,6 +21,6 @@ class Glue {
        val inputQueueName = inputChannel.queueDeclare().queue
        inputChannel.queueBind(inputQueueName, envConfig.mqInputExchange, "")

-        inputChannel.basicConsume(envConfig.mqInputExchange, true, GlueConsumer())
+        inputChannel.basicConsume(inputQueueName, true, GlueConsumer())
    }
 }