А (емитят много событий). Есть один сервис типа B - слушает и агрегирует данные по событиям. Есть сервис C, который получает данные от B, чтоб броадкастить фронту.
Вся это дичь общается через rabbitMQ exchange.
A1 A2 A3 => B => C
Как правильно реализовать создание exchange-ей? консюмер всегда создает exchange-ы? или продюсеры всегда?
Просто если каждый сервис создает, то получается дичь - exchange-ы затираются друг другом, обмен сообщениями не начинается.
Или может нужен сервис-арбитр - следить за этим зоопарком и поднимать недостающие exchang-ы?
Сначала делайте bind, если ошибка - declare и потом bind
Обсуждают сегодня