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, "")