diff --git a/cnn_classification_service/main.py b/cnn_classification_service/main.py
index 0789212..17c3490 100644
--- a/cnn_classification_service/main.py
+++ b/cnn_classification_service/main.py
@@ -55,12 +55,12 @@ def main():
     logging.info("Connecting to MQ service...")
     connection = pika.BlockingConnection(pika.connection.URLParameters(os.environ['PIKA_URL']))
     channel = connection.channel()
-    channel.exchange_declare(exchange=os.environ['PIKA_INPUT_EXCHANGE'], exchange_type='fanout')
+    channel.exchange_declare(exchange=os.environ['PIKA_INPUT_EXCHANGE'], exchange_type='direct')
 
     queue_declare_result = channel.queue_declare(queue='', exclusive=True)
     queue_name = queue_declare_result.method.queue
 
-    channel.queue_bind(exchange=os.environ['PIKA_INPUT_EXCHANGE'], queue=queue_name)
+    channel.queue_bind(exchange=os.environ['PIKA_INPUT_EXCHANGE'],routing_key='feature', queue=queue_name)
 
     channel.basic_consume(queue=queue_name, on_message_callback=message_callback, auto_ack=True)