如何配置自定义Spring，使其继续使用@SqsListener

Question

我试图让SpringCloud AWS使用自定义的SimpleMessageListenerContainerFactory，以便设置超时和最大消息数。如果没有使用SQS中的SimpleMessageListenerContainerFactory很好地拾取消息来注释的自定义@SqsListener方法，那么。但是，当我试图配置自定义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;
}

在定义自定义SimpleMessageListenerContainerFactory时，如何获得正常的@SqsListener行为？

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

Answer 1

不确定您漏掉了什么，但是对于这样的用例有一个测试：

@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是带有自定义SimpleMessageListenerContainerFactory @Bean的@Autowired。