From ce1aa81dbdaf3d6a188a15bca1e702f38ada039f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?P=C3=BCnk=C3=B6sd=20Marcell?= Date: Thu, 19 Aug 2021 04:12:00 +0200 Subject: [PATCH] fixes, hopefully --- src/main/kotlin/mq/ConsumerWrapper.kt | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/kotlin/mq/ConsumerWrapper.kt b/src/main/kotlin/mq/ConsumerWrapper.kt index a3ca196..0d7095f 100644 --- a/src/main/kotlin/mq/ConsumerWrapper.kt +++ b/src/main/kotlin/mq/ConsumerWrapper.kt @@ -16,9 +16,9 @@ class ConsumerWrapper { val inputConnection = factory.newConnection() val inputChannel = inputConnection.createChannel() - inputChannel.exchangeDeclare(envConfig.mqExchange, BuiltinExchangeType.FANOUT) + inputChannel.exchangeDeclare(envConfig.mqExchange, BuiltinExchangeType.DIRECT) val inputQueueName = inputChannel.queueDeclare().queue - inputChannel.queueBind(inputQueueName, envConfig.mqExchange, "") + inputChannel.queueBind(inputQueueName, envConfig.mqExchange, "meta") inputChannel.basicConsume(inputQueueName, false, DatabaseConsumer(inputChannel)) }