Установление барьера после группы сообщений

Question

Я создаю группы сообщений (например, G1, G2, ...).

Внутри каждой группы все сообщения могут обрабатываться параллельно, порядок не имеет значения.

Однако,чтобы обработать G2, все сообщения от G1 должны были закончить обработку.

Возможно ли реализовать это в rabbitmq?(наконец, я реализую это в Symfony ...)

Мой вопрос связан с Очередью сообщений с функцией 'Барьер сообщений'?

Answer 1

Очереди не подходят для таких сценариев.Используйте оркестратор, такой как Cadence Workflow , который поддерживает ваш сценарий "из коробки".Это также позволяет реализовать сложные политики обработки ошибок и повторных попыток.