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