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

Question

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

Я особенно заинтересован в изменении стандартного 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;
}