From 4825f54c891dbee2f091721066fa97fd0284f208 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Torma=20Krist=C3=B3f?= <tormakristof@tormakristof.eu>
Date: Wed, 11 Aug 2021 15:08:31 +0200
Subject: [PATCH] use direct exchange

---
 src/Application.kt | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/Application.kt b/src/Application.kt
index 6c1a1c1..1257148 100644
--- a/src/Application.kt
+++ b/src/Application.kt
@@ -51,7 +51,7 @@ fun Application.module() {
 
     val rabbitExchangeName = appConfig.property("ktor.mq.exchange").getString()
 
-    channel.exchangeDeclare(rabbitExchangeName, BuiltinExchangeType.FANOUT)
+    channel.exchangeDeclare(rabbitExchangeName, BuiltinExchangeType.DIRECT)
     val queueName = channel.queueDeclare().queue
     channel.queueBind(queueName, rabbitExchangeName, "")