Потребитель нескольких компонентов Camel для одной очереди AWS SQS FIFO - PullRequest
0 голосов
/ 29 апреля 2020

В приложении, которое я создал, есть верблюжий компонент, который потребляет из AWS SQS Delayed Queue:

from("aws-sqs://" + queueName + "?amazonSQSClient=#sqsClient&maxMessagesPerPoll=10&receiveMessageWaitTimeSeconds=20")
.log("Consumed message from queue ! ${body}").to("direct:consumeMessage");

Очередь, из которой мы потребляем, является Delayed Queue. Приложение было развернуто в двух экземплярах EC2. Теперь функциональное требование таково: необходимо получить все ожидающие сообщения по истечении времени задержки, нам нужно получить все сообщения в одном экземпляре EC2. Но теперь сообщения используются обоими приложениями экземпляра, поскольку потребление было развернуто в обоих экземплярах EC2. Попытка "concurrentConsumer = 1", которая также не работала.

Не получала особой помощи по указанному ниже URL-адресу. Пожалуйста, нужна поддержка. Заранее спасибо. Пожалуйста, дайте мне знать, если вам нужен какой-либо ввод.

Apache Верблюд не получает сообщение от SQS своевременно

...