amqp Limit unack message

Hi,

How can I limit my receiver to receive only 5 or another number of unack message to avoid to receive all messages that are in the queue ?

Thanks

Sep 10 '19 20:09 jonathanroze

I believe if you set LinkCredit as show in this example, it will limit your receiver from receiving more than the number specified in LinkCredit before providing a disposition for a message.

Also, there's pretty solid docs associated with that option here: https://godoc.org/pack.ag/amqp#LinkCredit.

Sep 10 '19 21:09 devigned

Thanks for your time Devigned, i already tried this property and my receive all messages that are in the queue !

I'm using Amazon MQ!

Sep 11 '19 07:09 jonathanroze

I tried to put sleep into my onMessage function and credit set to 10, but in this case, i can read just one by one message !

Sep 11 '19 09:09 jonathanroze

Share some code. Happy to give it a look.

Sep 11 '19 14:09 devigned

I agree, without the code it's difficult to advise on what might be happening.

onMessage isn't part of this library's API, but you'd need to be handling them in separate goroutines to get more than one at a time.

For what you're asking for to work you also need to be negotiating amqp.LinkSenderSettle(amqp.ModeUnsettled) otherwise the broker could be sending you messages that are already settled and there's nothing to ack.

Sep 11 '19 15:09 vcabbage