Слушатель очереди 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;
}
Другие вопросы по тегам