search

taskiq-python / taskiq-aio-pika

AMQP broker for taskiq
21 stars 10 forks source link

feat: multiple queues #17

Open vvanglro opened 1 year ago

vvanglro commented 1 year ago

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

16

vvanglro commented 1 year ago

It seems that you only need to increase the queue_name parameter in BrokerMessage. https://github.com/vvanglro/taskiq-aio-pika/blob/feat/multiple_queues/taskiq_aio_pika/broker.py#L223-L229