[ https://issues.apache.org/activemq/browse/AMQ-1027?page=comments#action_37621 ] Kieran Murphy commented on AMQ-1027: ------------------------------------
My testing shows also that if a client is shutdown after failover but before it has processed all of its prefetched messages, then those messages are not received by any other consumer -- they are lost without having been consumed. > Failover transport incorrectly handles prefetched messages > ---------------------------------------------------------- > > Key: AMQ-1027 > URL: https://issues.apache.org/activemq/browse/AMQ-1027 > Project: ActiveMQ > Issue Type: Bug > Components: Connector > Affects Versions: 4.0.2 > Environment: Linux (Kernel 2.6), jdk 1.5.0_08 > Reporter: Danielius Jurna > Attachments: FailoverConsumerTest.java > > > After failover transport reconnect, if there is prefetched messages on the > client, client sends invalid ack messages to the server. After that client > stops receiving messages and it must be restarted. > This happens only when there are more messages in the queue, than queue > prefetch size. > There is attached test case, which reproduces this error. Unfortunately, > theres error in NetworkTestSupport.restartRemoteBroker() (after restart > client cannot receive messages left in the queue). So you must use external > broker an restart it manually, when the test asks you to do that. Should I > report this bug in Component "Test cases"? -- 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
