В мою систему отправляется больше количество сообщений из разных систем. Допустим, сообщения для автомобилей разных марок.
При каждой отправке новой марки автомобилей из какой-либо системы создается новая очередь (например, auto.kia
, auto.lada
и т.п.) в итоге в реббите может быть произвольное количество очередей.
Но, у меня есть один воркер (Consumer), который должен собирать и обрабатывать сообщения из всех этих очередей. Как реализовать множества очередей одним воркером?