File tree Expand file tree Collapse file tree 2 files changed +6
-3
lines changed
Expand file tree Collapse file tree 2 files changed +6
-3
lines changed Original file line number Diff line number Diff line change @@ -28,7 +28,7 @@ async def test() -> None:
2828
2929### Default delays
3030
31- To send delayed messagem , you need to specify queue for delayed messages. You can do it by passing ` delay_queue ` parameter to the broker. For example:
31+ To send delayed message , you need to specify queue for delayed messages. You can do it by passing ` delay_queue ` parameter to the broker. For example:
3232
3333``` python
3434from taskiq_aio_pika import AioPikaBroker, Queue, QueueType
Original file line number Diff line number Diff line change @@ -72,7 +72,7 @@ def __init__(
7272 :param url: url to rabbitmq. If None,
7373 the default "amqp://guest:guest@localhost:5672" is used.
7474 :param result_backend: custom result backend.
75- :param task_id_generator: custom task_id genertaor .
75+ :param task_id_generator: custom task_id generator .
7676 :param qos: number of messages that worker can prefetch.
7777 :param loop: specific even loop.
7878 :param exchange: parameters of exchange that used to send messages.
@@ -247,7 +247,7 @@ async def _declare_queues(
247247 declared by aio-pika.
248248
249249 :param channel: channel to used for declaration.
250- :return: main queue instance .
250+ :return: list of declared queues and their consumer arguments .
251251 """
252252 await self ._declare_dead_letter_queue (channel )
253253 declared_queues = []
@@ -323,6 +323,9 @@ def with_queue(self, queue: Queue) -> Self:
323323 """
324324 Add new queue to the broker.
325325
326+ This method should be called before startup,
327+ otherwise the new queue won't be declared and bound to exchange.
328+
326329 :param queue: queue to add.
327330 :return: self.
328331 """
You can’t perform that action at this time.
0 commit comments