Replies: 1 comment
-
Hey @peeteko, I'm not sure I understand your question, but yes, you can use That's not exactly the same as controlling how many polling threads you have - the framework uses non-blocking logic behind the scenes and controls how many concurrent polls each queue will have according to how many concurrent messages you want to process. Example: @SqsListener(queues = "${queueu1}", maxConcurrentMessages="100")
@SqsListener(queues = "${queueu2}", maxConcurrentMessages="10") Does that answer your question? |
Beta Was this translation helpful? Give feedback.
0 replies
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Uh oh!
There was an error while loading. Please reload this page.
-
We use in our spring boot project a few classes with methods with a @SQSListener annotations. I would like that some methods have a higher number of reading threads and other a lower number of reading threads
I think we can use maxConcurrentMessages
https://docs.awspring.io/spring-cloud-aws/docs/3.2.0/reference/html/index.html#other-annotation-properties
What is the exact syntax to add this in the annotation. How do you specify the property maxConcurrentMessages
@SqsListener("${queueu1}")
public void processQueu1(){
@SqsListener("${queueu2}")
public void processQueu2(){
Beta Was this translation helpful? Give feedback.
All reactions