Migration Issue: QueueMessageChannel Replacement in Spring Boot 3

[ShaikMerge]

Hi everyone,

We are currently in the process of migrating our application from Spring Boot 2 to Spring Boot 3. As part of this migration, we are updating to the latest AWS SDK v2 and Spring Cloud AWS 3. However, we have encountered an issue with the QueueMessageChannel functionality, which seems to have been completely changed in the new version.

Problem:
In Spring Boot 2, we used QueueMessageChannel for our queue operations. However, we cannot find a direct replacement for QueueMessageChannel in Spring Boot 3 and Spring Cloud AWS 3.

Question:
How can we implement the same functionality as QueueMessageChannel in Spring Boot 3 using the latest AWS SDK v2 and Spring Cloud AWS 3? Is there a recommended approach or alternative that we should use?

Any guidance or examples would be greatly appreciated!

Thank you!

[Aliabbos-Ashurov]

Try using SqsMessageDrivenChannelAdapter or @SqsListener.

Example:

@Bean
public SqsMessageDrivenChannelAdapter sqsAdapter(AmazonSQSAsync amazonSQSAsync) {
    return new SqsMessageDrivenChannelAdapter(amazonSQSAsync, "your-queue-name");
}. 

Or use SqsClient for manual polling:

@Autowired
public SqsPollingService(SqsClient sqsClient) {
    this.sqsClient = sqsClient;
}

public void pollMessages() {
    ReceiveMessageRequest request = ReceiveMessageRequest.builder()
        .queueUrl("your-queue-url")
        .maxNumberOfMessages(10)
        .build();

    List<Message> messages = sqsClient.receiveMessage(request).messages();
    messages.forEach(msg -> System.out.println("Received: " + msg.body()));
}  

[ShaikMerge]

Thanks for the example will try this and let you know