Надёжно, потому что просто
Любое событие снаружи (сделка сменила стадию, пришло сообщение, наступило время) превращается в задачу в очереди. Задачу забирает воркер и исполняет инструкцию: цепочку блоков со своими проверками. Каждый шаг проверяется по контракту, каждая отправка пишется в журнал. К базе ходит один сервис, остальные обращаются к нему, поэтому данные не расходятся.
Ночью упал Telegram. Утром очередь сама доставила накопившиеся сообщения, а в журнале видно, какие и когда.
Что это даёт
Как это работает
- Любое событие сначала записывается как задача, и только потом обрабатывается.
- Воркер исполняет инструкцию; каждый шаг проверяется по контракту.
- К базе ходит один сервис; остальные обращаются к нему через типизированные команды.
Что настраивается
- Число повторов и интервалы.
- Приоритеты очередей.
- Что считать ошибкой, а что — нормальным ответом внешнего сервиса.
Что нужно от вас
Ничего: это устройство платформы, оно одинаково для всех проектов.
Показать этот модуль на вашей задаче?
За 30 минут посмотрим, как он ляжет на ваш процесс, и скажем, что включается сразу, а что требует настройки.