fix: correct rmq delayed handler router registration

README.md

@@ -231,8 +231,9 @@ The availability of such documentation significantly simplifies the integration
 
 **FastStream** (thanks to [**FastDepend**](https://lancetnik.github.io/FastDepends/)) has a dependency management system similar to `pytest fixtures` and `FastAPI Depends` at the same time. Function arguments declare which dependencies you want are needed, and a special decorator delivers them from the global Context object.
 
-```python linenums="1" hl_lines="9-10"
+```python
 from faststream import Depends, Logger
+
 async def base_dep(user_id: int) -> bool:
     return True
 

faststream/__about__.py

@@ -1,5 +1,5 @@
 """Simple and fast framework to create message brokers based microservices"""
-__version__ = "0.1.1rc0"
+__version__ = "0.1.1"
 
 
 INSTALL_YAML = """

faststream/rabbit/shared/router.py

@@ -52,9 +52,11 @@ def __init__(
             The above docstring is autogenerated by docstring-gen library (https://docstring-gen.airt.ai)
         """
         for h in handlers:
-            q = RabbitQueue.validate(h.kwargs.pop("queue", h.args[0]))
-            new_q = model_copy(q, update={"name": prefix + q.name})
-            h.args = (new_q, *h.args[1:])
+            if (q := h.kwargs.pop("queue", None)) is None:
+                q, h.args = h.args[0], h.args[1:]
+            queue = RabbitQueue.validate(q)
+            new_q = model_copy(queue, update={"name": prefix + queue.name})
+            h.args = (new_q, *h.args)
 
         super().__init__(prefix, handlers, **kwargs)
 

tests/brokers/rabbit/test_router.py

@@ -53,7 +53,7 @@ def response(m):
         r_queue = RabbitQueue(queue)
 
         r = type(router)(
-            prefix="test/", handlers=(self.route_class(response, r_queue),)
+            prefix="test/", handlers=(self.route_class(response, queue=r_queue),)
         )
 
         pub_broker.include_router(r)