From fcb35bae016596da2796893b226b0480dd2ea043 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Torma=20Krist=C3=B3f?= Date: Fri, 22 May 2020 04:34:51 +0200 Subject: [PATCH] queue name --- src/main/kotlin/worker/Glue.kt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/kotlin/worker/Glue.kt b/src/main/kotlin/worker/Glue.kt index f271b8f..c9a8c39 100644 --- 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()) } } \ No newline at end of file