activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Komandur <sridharkoman...@komandur.com>
Subject Re: [jira] Commented: (AMQ-850) add the ability to timeout a consumer to
Date Wed, 09 Aug 2006 19:48:41 GMT

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.


Mime
View raw message