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)

Most upvoted comments

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.