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))
     }