From d17ea80de06c6435ec268f32696ff1104c0b4f7e Mon Sep 17 00:00:00 2001 From: Gijs Vermeulen Date: Thu, 1 Feb 2024 15:30:42 +0100 Subject: [PATCH] Pass body as json to wrapped function --- pyproject.toml | 2 +- src/amqpstorm_flask/RabbitMQ.py | 8 ++++++-- 2 files changed, 7 insertions(+), 3 deletions(-) diff --git a/pyproject.toml b/pyproject.toml index e6c5aae..58caa3b 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -6,7 +6,7 @@ build-backend = "setuptools.build_meta" [project] name = "amqpstorm-flask" -version = "0.1.9" +version = "0.2.0" description = "amqpstorm library for Flask" readme = "README.md" authors = [{ name = "Inuits", email = "developers@inuits.eu" }] diff --git a/src/amqpstorm_flask/RabbitMQ.py b/src/amqpstorm_flask/RabbitMQ.py index 53e4eb5..dc9ade7 100644 --- a/src/amqpstorm_flask/RabbitMQ.py +++ b/src/amqpstorm_flask/RabbitMQ.py @@ -161,7 +161,7 @@ def __create_wrapper_function(self, routing_key, f): def wrapper_function(message): f( routing_key=routing_key, - body=message.body, + body=message.json(), message_id=message.message_id, ) @@ -221,7 +221,11 @@ def new_consumer(): if retries > max_retries: exit(0) - self.logger.exception(ex) + self.logger.exception( + "An error occurred while consuming queue %s: %s", + queue_name, + ex, + ) self.logger.warning(f"Retrying in {retry_delay} seconds...") sleep(retry_delay)