Слушатель очереди SQS (Springboot)
Как управлять запросом с помощью SQS. Предположим, что 4 запроса отправлены одновременно в SQS, а затем нужно обрабатывать только по одному. Как только первый завершится, возьмите второй запрос из очереди в процессе, и этот процесс необходимо продолжить.
Я использовал @SqsListener в springboot для получения полезной нагрузки сообщения.
1 ответ
Вы можете определить bean-компонент SimpleMessageListenerContainerFactory и настроить поведение слушателя следующим образом:
@Bean
public SimpleMessageListenerContainerFactory simpleMessageListenerContainerFactory(AmazonSQSAsync amazonSqs) {
SimpleMessageListenerContainerFactory factory = new SimpleMessageListenerContainerFactory();
[...]
factory.setAmazonSqs(amazonSqs);
factory.setMaxNumberOfMessages(1);
[...]
return factory;
}