несколько слушателей 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) {