Установление барьера после группы сообщений - PullRequest
0 голосов
/ 23 сентября 2019

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

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

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

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

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

1 Ответ

0 голосов
/ 24 сентября 2019

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

...