#rabbitmq
Вопрос:
У меня есть служба с 3 блоками, и есть очередь/тема кролика MQ, из которой потребители будут получать сообщение
Как только поступают сообщения, бизнес-логика такова, что каждые 30 секунд мне нужно консолидировать все записи, поступившие для определенного идентификатора, и заменить исходный документ консолидированным документом
но проблема в том, что, поскольку существует 3 модуля, сообщения помещаются в них случайным образом
Я хочу знать, есть ли способ сопоставить ч/б модуль и очередь/тему и убедиться, что сообщения, поступающие в эту очередь/тему, каждый раз попадают в 1 конкретный модуль
или любые другие решения этой проблемы