send json dict to mq

2020-04-30 00:17:16 +02:00 · 2020-04-30 00:17:16 +02:00 · 2d36ed6991
commit 2d36ed6991
parent e756ff614a
1 changed files with 1 additions and 1 deletions
--- a/src/resources.py
+++ b/src/resources.py
@ -79,7 +79,7 @@ class SampleResource(Resource):
            rabbitmq_channel.basic_publish(
                exchange=RABBITMQ_EXCHANGE,
                routing_key='feature',
-                body=generated_tag)
+                body=json.dumps({'tag': generated_tag}).encode('utf-8'))
        except Exception as e:
            LOGGER.exception(e)
            db.session.rollback()