What is the purpose of the prefetchExtension counter in TopicSubscription.java (AMQ 4.2)? Not sure what is trying to be accomplished, but one way or another, the way it is implemented / used is causing the isFull method to never return true. In fact, PrefetchSize in jconsole shows an ever increasing number, which is what first attracted my attention - since PrefetchSize is not something that normally changes once set. Since isFull doesn't work, then discarding policies don't work...
There are several methods in TopicSubscription.java that reference prefetchExtension, and if that counter is ever increasing, as it is right now, those methods won't work properly. That would include the previously mentioned isFull, but also isLowWaterMark, isHighWaterMark. I can open a JIRA issue, but thought I'd post it here first as a question. -- View this message in context: http://www.nabble.com/AMQ-4.2-issue-with-prefetchExtension-in-TopicSubscription.java-tf3494033s2354.html#a9759063 Sent from the ActiveMQ - User mailing list archive at Nabble.com.