birbnetes/input-service
birbnetes/input-service
4
0
Fork 0
Code Pull Requests Releases Activity

oops
All checks were successful
continuous-integration/drone/push Build is passing
Details

Browse Source
This commit is contained in:
Torma Kristóf 2020-10-19 23:48:59 +02:00
parent b47d9df26d
commit edc22a4e0a
Signed by: tormakris
GPG Key ID: DC83C4F2C41B1047
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/resources.py
View File

@ -91,9 +91,9 @@ class SampleResource(Resource):
heartbeat=0, heartbeat=0,
socket_timeout=5)) socket_timeout=5))
channel = connection.channel() 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') 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', routing_key='feature',
body=json.dumps({'tag': generated_tag}).encode('UTF-8')) body=json.dumps({'tag': generated_tag}).encode('UTF-8'))
connection.close() connection.close()