Achieve concurrency with reactive messaging SQS

[prakashelango]

As we use SQS reactive messaging

1. docs shows as experimental does this applies for only Kafka or for all reactive messaging (SQS)?
2. Is there a way to achieve concurrency if it's an experimental feature any other alternate suggestions
3. SQS reactive messaging is in preview is that good to use in prod?

[ozangunalp]

The SQS connector is in preview because it lacks some tests we may have on other connectors.
For example the concurrency feature (which is not Kafka specific) that you mentioned should work, but we don't have the tests for it.
This is where the community feedback and contributions are very valuable.

Another way to process messages concurrently is using @Blocking(ordered = false)

[prakashelango]

I see, when we leverage blocking along with virtual threads do we need to set executor pool concurrency?

Do you mind pointing to tests let’s me give an attempt to add it.

[ozangunalp]

It'll look something like https://github.com/smallrye/smallrye-reactive-messaging/blob/main/smallrye-reactive-messaging-amqp/src/test/java/io/smallrye/reactive/messaging/amqp/ConcurrentProcessorTest.java

[ozangunalp]

For virtual-threads usage you can refer to https://quarkus.io/guides/messaging#execution-model or https://quarkus.io/guides/messaging-virtual-threads