How to use AWS SQSExtendedClient library to make it work asynchrously using JMSListener java

59 views Asked by At

Am trying to achieve exactly what the below link is trying to do.

Amazon SQS Async Listener for the Extended Client Library using Spring JmsListener

I couldn't find AmazonS3Client and AmazonSQSAsync class using below example. Did any get to this point ?

@Bean
public ConnectionFactory connectionFactory(final AmazonS3Client amazonS3Client, final AmazonSQSAsync amazonSqs) {
    final ExtendedClientConfiguration extendedClientConfig = new ExtendedClientConfiguration()
            .withLargePayloadSupportEnabled(amazonS3Client, "my-bucket-name");

    final ProviderConfiguration providerConfiguration = new ProviderConfiguration();
    providerConfiguration.setNumberOfMessagesToPrefetch(10);

    final SQSConnectionFactory sqsConnectionFactory = new SQSConnectionFactory(providerConfiguration,
            new AmazonSQSExtendedClient(amazonSqs, extendedClientConfig));

    return sqsConnectionFactory
}

Could someone help answering this question. Is there similar thing anyone faced ? Help Appreciated!

0

There are 0 answers