如何使用注释配置 Spring Cloud AWS 消息传递？

Question

如何使用注释配置 Spring Cloud AWS XML 配置？

我对更改默认任务执行器特别感兴趣。

Answer 1

我发现有 SimpleMessageListenerContainerFactory 用于通过 Java 配置 AWS 消息传递。 因此，更改默认 taskExecutor 只是覆盖此默认容器工厂 bean 的问题。像这样的：

@Bean
public SimpleMessageListenerContainerFactory simpleMessageListenerContainerFactory(AmazonSQSAsync amazonSqs) {
    SimpleMessageListenerContainerFactory factory = new SimpleMessageListenerContainerFactory();
    factory.setAmazonSqs(amazonSqs);
    Executor executor = Executors.newFixedThreadPool(1);
    ConcurrentTaskExecutor taskExecutor = new ConcurrentTaskExecutor(executor);
    factory.setTaskExecutor(taskExecutor);
    return factory;
}