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