несколько слушателей sqs, указывающих на одну и ту же очередь sqs fifo

У меня есть приложение springboot, которое прослушивает очередь sqs fifo с использованием spring cloud aws. Приложение кластеризовано и имеет 2 узла. Оба узла слушают одну и ту же очередь, и это приводит к некоторым проблемам с параллелизмом, когда слушатель почти сразу обрабатывает один и тот же тип сообщений. Существуют ли какие-либо настройки уровня очереди, чтобы гарантировать, что второй кластерный узел извлекает сообщения только после того, как первый узел обработает текущий пакет сообщений?

Вот мой код слушателя:

        @SqsListener(value = {"quue-url"}, deletionPolicy = SqsMessageDeletionPolicy.ON_SUCCESS)
    public void processMessage(String message, @Headers MessageHeaders headers) {

0 ответов

Другие вопросы по тегам