Блог

Я пытаюсь заставить SpringCloud AWS SQS работать с пользовательским SimpleMessageListenerContainerFactory , чтобы я мог устанавливать тайм-ауты и максимальное количество сообщений. Без пользовательских SimpleMessageListenerContainerFactory методов, которые снабжены аннотациями с сообщениями о @SqsListener приятном получении, которые находятся в SQS. Но когда я пытаюсь настроить пользовательский SimpleMessageListenerContainerFactory , аннотация перестает работать.

 @Bean
public SimpleMessageListenerContainerFactory simpleMessageListenerContainerFactory(AmazonSQSAsync amazonSqs) {
    SimpleMessageListenerContainerFactory factory = new SimpleMessageListenerContainerFactory();
    factory.setAmazonSqs(amazonSqs);
    factory.setAutoStartup(true);
    factory.setMaxNumberOfMessages(10);
    factory.setWaitTimeOut(2000);
    return factory;
}
  

Как я могу получить обычное поведение @SqsListener при определении пользовательского SimpleMessageListenerContainerFactory?

 @Component
public class SqsMessageConsumer {
    @SqsListener("incoming-data")
    private void doSomething(String payload) {
        System.out.println("data = "   payload);
    }
}
  

Не уверен, что вы пропустили, но есть тест именно для такого варианта использования:

 @EnableSqs
@Configuration
public static class ConfigurationWithCustomContainerFactory {


    @Bean
    public SimpleMessageListenerContainerFactory simpleMessageListenerContainerFactory() {
        SimpleMessageListenerContainerFactory factory = new SimpleMessageListenerContainerFactory();
        factory.setAmazonSqs(amazonSQS());
        ...
        return factory;
    }

    @Bean
    public AmazonSQSAsync amazonSQS() {
        return AMAZON_SQS;
    }

}
  

Итак, @EnaqbleSqs оно все еще здесь и SqsConfiguration @Autowired с вашим пользовательским SimpleMessageListenerContainerFactory @Bean .