From 236b08798bb3edce18c7a7f1c76627434264f0ee Mon Sep 17 00:00:00 2001 From: Matthias Dillen Date: Thu, 14 Mar 2024 16:58:35 +0100 Subject: [PATCH] bugfix auto_ack --- pyproject.toml | 2 +- src/amqpstorm_flask/RabbitMQ.py | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/pyproject.toml b/pyproject.toml index 8a13361..9e4faff 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -6,7 +6,7 @@ build-backend = "setuptools.build_meta" [project] name = "amqpstorm-flask" -version = "0.3.1" +version = "0.3.2" 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 4fb9fc8..b4b67e5 100644 --- a/src/amqpstorm_flask/RabbitMQ.py +++ b/src/amqpstorm_flask/RabbitMQ.py @@ -179,7 +179,7 @@ def queue( self, routing_key: Union[str, List[str]], exchange_type: str = "topic", - auto_ack: bool = False, + auto_ack: bool = None, dead_letter_exchange: bool = False, props_needed: List[str] | None = None, exchange_name: str = None, @@ -218,7 +218,7 @@ def new_consumer(): self.channel.basic.qos(prefetch_count=prefetch_count) cb_function = f if full_message_object else self.__create_wrapper_function(routing_key, f) self.channel.basic.consume( - cb_function, queue=queue, no_ack=self.queue_params.no_ack if auto_ack is False else auto_ack + cb_function, queue=queue, no_ack=self.queue_params.no_ack if auto_ack is None else auto_ack ) self.channel.queue.bind( queue=queue,