bugfix auto_ack

inuits · Mar 14, 2024 · 236b087 · 236b087
1 parent a3ebec5
commit 236b087
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git 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 = "[email protected]" }]

diff --git 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,