Как организовать достраивание сообщения несколькими сервисами?

Question

[Александр]

Есть потребитель. который запрашивает данные (создает сообщение в очередь) и по итогу ждет ответ (не суть важно в как именно).

Есть 10 сервисов которые обладают частью знаний о запрашиваемом объекте. Каждый сервис видит сообщение (дай мне данные по id =10) и дополняет сообщение своей частью знания об этом объекте. Когда объект оказывается полон (заполнен список сервисов по типам, ответ которых нам нужен), он возвращается потребителю.

Вопрос:
Как используя кролика организовать "достраивание" объекта внутри сообщения? Возможно ли вообще такое? Возможно есть какие-либо правильные паттерны для подобного?

Answer 1

[Сергей]

Какой-то сложный алгоритм, имхо.
Заранее известно определение "полноты" объекта? Если известен список сервисов, почему не обратиться к ним напрямую и по итогу ответов от каждого сформировать "полный" объект?
В общем нужен какой-то "редьюсер" ответов, из коробки у RMQ не знаю каких-то подходящих механизмов для этого.

Comments

[Александр]

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

Так сложно, потому, что эти сервисы будут долго "сбоку" и вводится постепенно. Сразу переключится на схему с очередями никак нельзя.