Camel active mq - Производитель, чтобы подтвердить, обрабатываются ли сообщения потребителем - PullRequest
0 голосов
/ 10 октября 2018

У нас есть служба производителя, которая публикует сообщение в теме, и у нас есть 3 случая, когда потребители читают это сообщение из темы.Производителю необходимо выполнять дальнейшую обработку (обновление БД) только тогда, когда все потребители обработали и ответили на сообщение об успешном завершении в другой очереди ответа.Даже если один из сервисов-потребителей отказал из-за какого-либо исключения или какого-либо сообщения об ошибке в очереди ответов, производитель не должен обновлять БД для этого запроса на публикацию.

Для следующего запроса (новое сообщение опубликовано в теме), если всепотребители обработали и ответили в очереди ответов, производитель должен обновить БД.Как мы можем добиться этого с верблюдом и activemq.Есть ли какие-либо шаблоны EIP для достижения этой цели?

Любой

1 Ответ

0 голосов
/ 10 октября 2018

Да, производитель может просто использовать шаблон интеграции предприятия aggregator в очереди ответов, чтобы все 3 потребителя обработали предыдущее сообщение.

Документ: Apache Camel aggregator2 компонент.

Вам потребуется уникальный ключ и используйте правильную стратегию агрегирования.

...