add default for queue type

airtai · Dec 21, 2024 · 67b448f · 67b448f
1 parent 535ada5
commit 67b448f
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 6 deletions.
diff --git a/faststream/rabbit/broker/broker.py b/faststream/rabbit/broker/broker.py
@@ -27,7 +27,6 @@
     RABBIT_REPLY,
     RabbitExchange,
     RabbitQueue,
-    RabbitQueueType,
 )
 from faststream.rabbit.security import parse_security
 from faststream.rabbit.subscriber.asyncapi import AsyncAPISubscriber
@@ -476,7 +475,7 @@ async def _connect(  # type: ignore[override]
             if max_consumers:
                 c = AsyncAPISubscriber.build_log_context(
                     None,
-                    RabbitQueue("", queue_type=RabbitQueueType.Classic),
+                    RabbitQueue(""),
                     RabbitExchange(""),
                 )
                 self._log(f"Set max consumers to {max_consumers}", extra=c)

diff --git a/faststream/rabbit/schemas/__init__.py b/faststream/rabbit/schemas/__init__.py
@@ -14,6 +14,4 @@
     "ReplyConfig",
 )
 
-RABBIT_REPLY = RabbitQueue(
-    "amq.rabbitmq.reply-to", passive=True, queue_type=RabbitQueueType.Classic
-)
+RABBIT_REPLY = RabbitQueue("amq.rabbitmq.reply-to", passive=True)
diff --git a/faststream/rabbit/schemas/queue.py b/faststream/rabbit/schemas/queue.py
@@ -131,7 +131,7 @@ def routing(self) -> str:
     def __init__(
         self,
         name: str,
-        queue_type: Literal[RabbitQueueType.Classic],
+        queue_type: Literal[RabbitQueueType.Classic] = RabbitQueueType.Classic,
         durable: Literal[True, False] = False,
         exclusive: bool = False,
         passive: bool = False,