Как я могу использовать сообщение ActiveMQ, когда требуемые данные находятся в подчиненном устройстве MongoDB?

Question

Это больше вопрос архитектуры программного обеспечения.

Скажем, я поместил некоторые данные в базу данных MongoDB и отправил сообщение ActiveMQ.Потребитель сообщения зависит от данных, присутствующих в MongoDB, но если по причинам масштабируемости потребитель использует ведомое устройство базы данных MongoDB, как я могу быть уверен, что сообщение будет использовано только тогда, когда данные находятся в реплике?

Я использую perl в качестве языка программирования, поэтому я бы предпочел, чтобы любые потенциальные решения были на высоком уровне, а не, например, в примере кода Java.

Answer 1

Поскольку нет интеграции между ActiveMQ и репликацией MongoDB, вы ограничены этим:

1. Просмотр сообщения из очереди.

2. Убедитесь, что необходимые данные присутствуют на ведомом устройстве.

3. Если присутствует, потреблять. В противном случае перейдите к следующему сообщению.

Answer 2

В качестве альтернативы ответу Серхио:

1. Получить сообщение из очереди (pop)

2. Убедитесь, что необходимые данныеприсутствует на рабе.

3. Если присутствует, потреблять.В противном случае повторно поместите сообщение в очередь.