AMQP Message consumption #34905
antoinechamot
started this conversation in
Community
Replies: 0 comments
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.
Uh oh!
There was an error while loading. Please reload this page.
-
I have the following consumer for rabbitmq
`
with
smallrye.messaging.worker.my-worker-pool.max-concurrency=3
With such configuration, I have only 3 messages process at the same time. The problem is that if I send let's say 5 messages the two non process messages will be in the queue in non acknowledge status instead of ready which prevent other consumer to take them.
How can i limit my channel to only those 3 messages and let other messages to ready status.
I have tried :
mp.messaging.incoming.incoming-msgmax-outstanding-messages=1.
With such parameter, it limits number of non acknowledge messages to 1, but it is not what i want (all messages ready except those 3 processing).
How can I do that ? Is it possible ? If not which strategy should i use for one consumer to let messages available if he is not able to process them
Beta Was this translation helpful? Give feedback.
All reactions