Я застрял в проблеме, когда мне нужно динамически создавать очереди, и эти очереди должны начать прослушивать все назначенные им активные задания. «Использование общей очереди» в моем случае неосуществимо, потому что задержка выполнения задачи увеличивается экспоненциально из-за длинной цепочки заданий в таких общих очередях.
Предположим, что есть следующие задания (A, B, C, D, E, F, .....)
пусть X будет единственной или последовательной очередью. Таким образом, отправка задания для очереди X выглядит следующим образом:
Очередь X = A, B, C, D, E, F, ......
В этом случае блокируются другие задания, которые могут одновременно обрабатываться другими очередями. Поэтому я хочу динамически создавать определенные очереди для каждой работы, попадающей в категорию. Для этих заданий создаются очереди (скажем, X, Y, Z, ...), такие что:
Очередь X = A, D, F
Очередь Y = B, E
Очередь Z = C
....и так далее.
Есть ли способ прослушивания всех тех очередей, для которых отправляются имена очередей?
Люблю знать.