Необходимо транслировать сообщение (один ко многим) с использованием платформы Anypoint MQ с правильной последовательностью (первым пришел - первым вышел)
Наше требование: SAP будет публиковать сообщения для N подписчиков, и эти подписчики будут получать опубликованные сообщения через свой индивидуальный временной интервал.
Мы разработали решение следующим образом: Создано N стандартных очередей под обмен. Широковещательная рассылка каждого сообщения от SAP во все эти N очередей. Опубликованный API для каждого подписчика для извлечения сообщений из их индивидуальных очередей. Для любого подписчика на добавление очередь создается с помощью регистрационного API, а имена очередей имеют шаблон с именем подписчика. До этого все в порядке. Но мы видим, что сообщения, поступающие из SAP, должны поддерживать последовательность, но стандартная очередь не может поддерживать последовательность. Если мы перейдем к очереди FIFO, мы не сможем транслировать сообщение SAP во все очереди вместе, как мы делаем это через обмен.
Мой вопрос в том, как мы можем по-прежнему создавать сообщения SAP для всех очередей, чтобы каждый подписчик мог читать из своего индивидуального пространства, а мы могли поддерживать последовательность сообщений в порядке "первым пришел - первым обслужен"?