AMQP: обрабатывать разные очереди в порядке объявления - PullRequest
0 голосов
/ 22 мая 2018

У меня есть обмен (RabbitMQ) с разными очередями, каждая очередь содержит сообщения, в которых важен порядок.

Я хочу выбрать и обработать самую раннюю объявленную очередь и прогресс в порядке создания.Как обмен, функционирующий как другая очередь.

Как мне добиться этого в AMQP?

1 Ответ

0 голосов
/ 22 мая 2018

Решается путем создания новой очереди для хранения уникальных идентификаторов других очередей.Поскольку это FIFO, элементы помещаются в очередь по порядку.В случаях, когда мы помещаем текущую обработанную очередь, мы просто нажимаем тот же идентификатор снова - поэтому, если не все сообщения были обработаны, их обработка ставится в очередь на потом.

...