From 5b736b284477d673e6de858d8590046d3a50fe96 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Torma=20Krist=C3=B3f?= <tormakristof@tormakristof.eu>
Date: Sat, 24 Oct 2020 00:28:25 +0200
Subject: [PATCH] use direct exchange

---
 src/resources.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/resources.py b/src/resources.py
index cded0f8..36fbe34 100644
--- a/src/resources.py
+++ b/src/resources.py
@@ -101,7 +101,7 @@ class SampleResource(Resource):
                                           socket_timeout=5))
             channel = connection.channel()
             channel.exchange_declare(exchange=current_app.config['EXCHANGE_NAME'],
-                                     exchange_type='fanout')
+                                     exchange_type='direct')
             channel.basic_publish(exchange=current_app.config['EXCHANGE_NAME'],
                                   routing_key='feature',
                                   body=json.dumps({'tag': generated_tag}).encode('UTF-8'))