From edc22a4e0ae36789d7586f33d081a318909304b6 Mon Sep 17 00:00:00 2001 From: Torma Date: Mon, 19 Oct 2020 23:48:59 +0200 Subject: [PATCH] oops --- src/resources.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/resources.py b/src/resources.py index 29dde91..f0ce022 100644 --- a/src/resources.py +++ b/src/resources.py @@ -91,9 +91,9 @@ class SampleResource(Resource): heartbeat=0, socket_timeout=5)) channel = connection.channel() - channel.exchange_declare(exchange=current_app.config['FLASK_PIKA_PARAMS']['EXCHANGE_NAME'], + channel.exchange_declare(exchange=current_app.config['EXCHANGE_NAME'], exchange_type='fanout') - channel.basic_publish(exchange=current_app.config['FLASK_PIKA_PARAMS']['EXCHANGE_NAME'], + channel.basic_publish(exchange=current_app.config['EXCHANGE_NAME'], routing_key='feature', body=json.dumps({'tag': generated_tag}).encode('UTF-8')) connection.close()