taskiq-aio-pika

taskiq-aio-pika copied to clipboard

multiple queues

7

Like this, I just give a simple example, or there may be other more elegant ways to create multiple queues. ```py from taskiq_aio_pika import AioPikaBroker broker = AioPikaBroker(queue_name="q1") broker.add_queue(queue_name="q2") #...

vvanglro

rebased on develop

djeer

Add additional params to AioPikaBroker.init

1

Hi, aio-pika supports params when declare exchange. I'd like to use these params > path: aio_pika.abc.AbstractRobustChannel.declare_exchange https://github.com/taskiq-python/taskiq-aio-pika/blob/8e00c4720b907b40764bb20b8494b673e59b9fd3/taskiq_aio_pika/broker.py#L135C13-L137C42

enlike

not working delay for large number seconds(next hour, day, ...)

7

Hi. When i try add litte number seconds in param `delay` - it working, i await and get execute planing task. But if i try add large number seconds(next 1...

ArtemIsmagilov

README typo

1

[lirary](https://github.com/taskiq-python/taskiq-aio-pika/blob/master/README.md?plain=1#L3C1-L3C1) should be *library*, I suppose

Lancetnik

feat: multiple queues

1

This is my first version of multi-queue implementation, and the support of taskiq project is also needed to realize multi-queue. #16

vvanglro

Quorum queues are new type of queues in RabbitMQ which is now taking over old mirrord queues. We need to add support for them, because mirrored queues are scheduled for...

s3rius

This feature can be used by complex retry algorithms and is very useful for some users.

s3rius

This feature is useful for all folks who don't want to have unprocessed messages.

s3rius

Closes #41

WiZeYAR