quarkus: Retrieving AMQP Messages returns 1000 messages and stops consuming
Describe the bug
When configuring the AMQP client and retrieving messages from the non-destructive AMQP queue using the @Incoming tag, it retrieves the first 1000 messages and then stops consuming. The amqp queue has more than 50k messages.
When trying the same mechanism in .Net, I am able to set the AMQP Source Distribution Mode to ‘copy’ which then allows me to retrieve all the messages from the AMQP queue.
What is the best way to retrieve all messages from AMQP and if possible, how do I set the distribution mode attribute to the AMQP client configuration to ‘copy’?
Expected behavior
All messages from the queue are consumed and processed.
Actual behavior
The first 1000 messages are consumed and processed and no more messages are received.
How to Reproduce?
No response
Output of uname -a or ver
No response
Output of java -version
17
Quarkus version or git rev
3.4.3
Build tool (ie. output of mvnw --version or gradlew --version)
apache-maven-3.8.2
Additional information
No response
About this issue
- Original URL
- State: open
- Created 7 months ago
- Comments: 19 (12 by maintainers)
It’s what I did, I added 2000 messages in a queue, and then consumed them without any issue. I used the Artemis dev service.