[ https://issues.apache.org/activemq/browse/AMQ-850?page=comments#action_36679 ] Vadim Pesochinskiy commented on AMQ-850: ----------------------------------------
Please remember that in addition to removing messages from the buffer (unacking) you need to make sure that you do not keep allocating new messages. Consumer has to be put to sleep until rcv or rcvNoWait is called on it. My 2 cents, thanks. > add the ability to timeout a prefetch buffer to prevent a single consumer > grabbing messages > ------------------------------------------------------------------------------------------- > > Key: AMQ-850 > URL: https://issues.apache.org/activemq/browse/AMQ-850 > Project: ActiveMQ > Issue Type: New Feature > Components: Broker > Reporter: james strachan > Fix For: 4.2 > > > If a MessageConsumer is created but not used, it still tends to get its > prefetch-buffer worth of messages. If it does not process them within a > specific time the consumer should either be closed, or the messages unacked > and flushed from the buffer so that the consumer does not hog the messages. -- This message is automatically generated by JIRA. - If you think it was sent incorrectly contact one of the administrators: https://issues.apache.org/activemq/secure/Administrators.jspa - For more information on JIRA, see: http://www.atlassian.com/software/jira
