We are using ActiveMQ 4.1.1 and a retroactive consumer does not receive all messages. OS: Windows 2003 Server Java: 1.5.0_11 In this particular case, we had 403 messages on the queue, we call receiveNoWait() in a loop and after N messages where N < 403, receiveNoWiat() returns nothing. The value of N varies depending on the prefetch count set. If prefetch is set to 1, then N varies between 2-10. If prefetch is 32, then N varies betweeen 30-70. If we don't set prefetch at all (I guess default is 1000), then we get all messages.
Each message is about 1Mbyte. We would like to set a prefetch to a lower number to avoid outofmemory exceptions in the consumer application. While calling receiveNoWiat(), is there something else we need to check? Any recommendations? Thanks, vasant -- View this message in context: http://www.nabble.com/ActiveMQ-4.1.1%3A-retroactive-consumer-not-getting-all-messages-tp16467798s2354p16467798.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
