SQSAsyncClient TaskExecutor Config

[jonhines]

I am in the middle of migrating my queue-listener apps to 3.0.0+ and I was wondering if someone knew how to define a taskExecutor/threadpool for the SqsMessageListenerContainerFactory.

Pre 3.0.0 I could wire up a taskExecutor and inject it into the SimpleMessageListenerContainerFactory like below, but I do not see how this is possible with the latest update.

Pre 3.0.0 SQS Config:

@Bean
    public SimpleMessageListenerContainerFactory simpleMessageListenerContainerFactory(
        AmazonSQSAsync amazonSqs)
    {
        SimpleMessageListenerContainerFactory factory = new SimpleMessageListenerContainerFactory();
        factory.setAmazonSqs(amazonSqs);
        factory.setAutoStartup(true);
        factory.setMaxNumberOfMessages(10);
        factory.setTaskExecutor(createDefaultTaskExecutor());
        factory.setAutoStartup(isSqsListenerEnabled);
        return factory;
    }
    protected AsyncTaskExecutor createDefaultTaskExecutor()
    {
        ThreadPoolTaskExecutor threadPoolTaskExecutor = new ThreadPoolTaskExecutor();
        threadPoolTaskExecutor.setThreadNamePrefix("Listener - ");
        threadPoolTaskExecutor.setCorePoolSize(4);
        threadPoolTaskExecutor.setMaxPoolSize(8);

        // No use of a thread pool executor queue to avoid retaining message to long in memory
        threadPoolTaskExecutor.setQueueCapacity(16);
        threadPoolTaskExecutor.afterPropertiesSet();

        return threadPoolTaskExecutor;
    }

Current 3.0.0 config:

    @Bean
    public SqsMessageListenerContainerFactory<Object> defaultSqsListenerContainerFactory()
    {
        return SqsMessageListenerContainerFactory
            .builder()
            .sqsAsyncClient(sqsAsyncClient())
            .configure(options -> options.acknowledgementMode(
                AcknowledgementMode.ON_SUCCESS))
            .build();
    }

    @Bean
    public SqsAsyncClient sqsAsyncClient()
    {
        return SqsAsyncClient.builder()
            .build();
    }

any ideas how we can finely tune our SqsAsyncClient in 3.0.0+?

[neiljbrown]

Hi @jonhines

The docs suggest this is supported. See the latest (3.0 RC2) reference guide section https://docs.awspring.io/spring-cloud-aws/docs/3.0.0-RC2/reference/html/index.html#providing-a-taskexecutor.

The SqsContainerOptions property you need to set is described in section https://docs.awspring.io/spring-cloud-aws/docs/3.0.0-RC2/reference/html/index.html#sqscontaineroptions-descriptions.

Neil.

[jonhines]

Thank you for the super prompt and accurate answer, Neil!

Much appreciated!