[jira] Commented: (AMQ-850) add the ability to timeout a consumer to prevent a bad, hung or unused consumer consumer from grabbing messages

[ https://issues.apache.org/activemq/browse/AMQ-850?page=comments#action_36741 ] Vadim Pesochinskiy commented on AMQ-850: Even with prefetchSize=1 you will already loose 1 message. Somehow people tend to assume that loosing 1 message is

[jira] Commented: (AMQ-850) add the ability to timeout a consumer to prevent a bad, hung or unused consumer consumer from grabbing messages

[ https://issues.apache.org/activemq/browse/AMQ-850?page=comments#action_36732 ] Sridhar Komandur commented on AMQ-850: -- James/Hiram, Here is another proposal for fixing this issue. At a high level, we need break the coupling between the

[jira] Commented: (AMQ-850) add the ability to timeout a consumer to prevent a bad, hung or unused consumer consumer from grabbing messages

[ https://issues.apache.org/activemq/browse/AMQ-850?page=comments#action_36733 ] james strachan commented on AMQ-850: Vadim: agreed in the case where the consumer just never processes any messages and the receive() method is never called. A

[jira] Commented: (AMQ-850) add the ability to timeout a consumer to prevent a bad, hung or unused consumer consumer from grabbing messages

[ https://issues.apache.org/activemq/browse/AMQ-850?page=comments#action_36734 ] james strachan commented on AMQ-850: Sridhar: I don't quite follow your suggestion. We kinda do what you suggest - the broker maintains a record of how many

[jira] Commented: (AMQ-850) add the ability to timeout a consumer to prevent a bad, hung or unused consumer consumer from grabbing messages

[ https://issues.apache.org/activemq/browse/AMQ-850?page=comments#action_36740 ] Maxim Fateev commented on AMQ-850: -- I think ideal solution would include self adjusting prefetch buffer size. At the beginning it couild be 1 but then increased