I read the link, reread the thread & I misunderstood the prefetch feature ... the broker is pushing messages into the clientside pre-fetch buffers upto the limit.
Here are some ideas, let me know what you think ... 1. can we use an 'elastic prefetch' buffer based on a sliding window (like in TCP) - this reacts to client (mis)behavior 2. When the broker detects a misbehaving client, reclaim the unAcked messages for other active consumers (and make the window size 0 or 1 in step 1 above) Thanks Regards - Sridhar Komandur -- View this message in context: http://www.nabble.com/-jira--Created%3A-%28AMQ-850%29-add-the-ability-to-timeout-a-prefetch-buffer-to-prevent-a-single-consumer-grabbing-messages-tf2014900.html#a5732625 Sent from the ActiveMQ - Dev forum at Nabble.com.
