Hello,<br><br>We are currently evaluating rabbitMQ for message passing between distributed nodes. We have a scenario where we could like to restrict the number of messages sent to a consume...<br>From the documentation i understand that using &#39;basic.qos&#39; is the way to go (yes.. we are playing around with the snapshot 1.6 version).<br>
<br>Now assuming we set the prefetch size to lets say 5 for a channel, everything works fine until the consumer encounters an error while processing a message.. in which case i would ideally like to have the consumer send a &#39;basic.reject&#39;, so that the same message may be sent to another consumer... I then realized that rabbitMQ doesnt support &#39;basic.reject&#39; and the prescribed way of handling this situation is to close the channel, which will lead to all un-acked message being resent... <br>
<br>This unfortunately means that if consumer encouters an error on 1 message, I would not be able to close the Channel immediately.. as there are still 4 messages outstanding... which means i would have to wait for all the other messages to finish processing before i can send all the successfull acks and then close th channel... during which time, i wont be able to accept anymore messages...<br>
<br>I was wondering if anyone might be able to enlighten me with a better way of doing things..<br><br>TIA<br>-Arun<br><br><br>