From 6114c999ef87c64f65258a56f0eac7996bb0af15 Mon Sep 17 00:00:00 2001 From: Ole H Date: Mon, 8 May 2023 13:11:06 +0200 Subject: [PATCH] passive as parameter according to documentation --- aio_pika/queue.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/aio_pika/queue.py b/aio_pika/queue.py index 79348067..cbd1d2f8 100644 --- a/aio_pika/queue.py +++ b/aio_pika/queue.py @@ -66,7 +66,7 @@ def __repr__(self) -> str: ) async def declare( - self, timeout: TimeoutType = None, + self, timeout: TimeoutType = None, passive: Optional[bool] = None ) -> aiormq.spec.Queue.DeclareOk: """ Declare queue. @@ -81,7 +81,7 @@ async def declare( exclusive=self.exclusive, auto_delete=self.auto_delete, arguments=self.arguments, - passive=self.passive, + passive=passive or self.passive, timeout=timeout, )