activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rkmq <r...@thesiglers.net>
Subject Re: [jira] Commented: (AMQ-2908) Slow consumer stops receiving messages because PrefetchSubscription.dispatched is filled with expired messages.
Date Fri, 21 Dec 2012 15:28:36 GMT
I recently observed (in 5.6.0) this behavior when using an xml file with
policy entry to configure the queuePrefetech such as:

                </policyEntry>  
                      <policyEntry queue="AA_TTL.TEST"
producerFlowControl="true" queuePrefetch="600"
                                            enableAudit="false"
memoryLimit="2mb" >
                        <pendingQueuePolicy>
                            <vmQueueCursor/>
                        </pendingQueuePolicy>
                    </policyEntry>

However, when tested configuring the prefetch as in the testcase using the
url, I do not observe the issue.

ActiveMQConnectionFactory factory = new
ActiveMQConnectionFactory("tcp://localhost:61616"+"?jms.prefetchPolicy.queuePrefetch=600");

This was verified in a functional system with external broker.  I believe a
modification to the testcase that configures the prefetch via policyEntry
rather than on the URL, may reproduce the issue.



--
View this message in context: http://activemq.2283324.n4.nabble.com/jira-Created-AMQ-2908-Slow-consumer-stops-receiving-messages-because-PrefetchSubscription-dispatched-tp2533931p4661014.html
Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.

Mime
View raw message