Как настроить обмен сообщениями Spring Cloud AWS с аннотациями?

Question

Как настроить XML-конфигурацию Spring Cloud AWS с аннотациями?

Меня особенно интересует изменение стандартного taskExecutor.

Answer 1

Я обнаружил, что SimpleMessageListenerContainerFactory используется для настройки обмена сообщениями AWS через Java. Поэтому изменение значения по умолчанию taskExecutor имеет значение для переопределения этого фабричного компонента контейнера по умолчанию. Примерно так:

@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;
}