That worked, but not with Active MQ 5.0, because the prefetchLimit apparently does not work in that version.
rajdavies wrote: > > your constantPendingMessageLimitStrategy limit property must be > greater than 0 > > thanks, > > Rob > > Rob Davies > http://fusesource.com > http://rajdavies.blogspot.com/ > > > On 2 Dec 2008, at 05:35, mar1394 wrote: > >> >> I'm using Active MQ 5.0 on a RedHat Linux system. >> >> I have a number of slow consumers in my network, but I cannot get >> the slow >> consumer policies to work. >> >> I have set the PrefetchSize on the connection URL. >> >> java.naming.provider.url=tcp://localhost:61614? >> connectionTimeout >> = >> 0 >> &jms >> .prefetchPolicy >> .all=1000&jms.useCopyOnSend=false&jms.useCompression=true >> >> I have tried each of these: >> >> <constantPendingMessageLimitStrategy limit="0"/> >> >> <prefetchRatePendingMessageLimitStrategy multiplier="1"/> >> >> And have tried various values for the maximum pending limit in my >> code with >> this: >> >> ActiveMQPrefetchPolicy prefetchPolicy = new >> ActiveMQPrefetchPolicy(); >> prefetchPolicy.setMaximumPendingMessageLimit(1000); >> >> >> ((ActiveMQConnection >> )this.connection).setPrefetchPolicy(prefetchPolicy); >> >> But in the JMX consoles, the entries for my subscribers show that >> PrefetchSize STARTs at 1000, and then it climbs from there, rather >> than >> remaining constant. On my slow consumers the DispatchedQueueSize >> grows until >> it is huge -- certainly way beyond any of the limits I have set. >> All the >> DiscardCounts are always 0. >> >> >> This in in my activemq.xml file: >> >> <!-- Destination specific policies using destination names or >> wildcards >> --> >> <destinationPolicy> >> <policyMap> >> <policyEntries> >> >> <policyEntry topic="mpcs.>" producerFlowControl="false" >> memoryLimit="512mb"> >> <dispatchPolicy> >> <!-- <roundRobinDispatchPolicy/> --> >> <!-- <strictOrderDispatchPolicy/> --> >> <simpleDispatchPolicy/> >> </dispatchPolicy> >> >> <messageEvictionStrategy> >> <oldestMessageEvictionStrategy/> >> </messageEvictionStrategy> >> >> <pendingMessageLimitStrategy> >> <constantPendingMessageLimitStrategy limit="0"/> >> <!-- <prefetchRatePendingMessageLimitStrategy >> multiplier="1"/> --> >> </pendingMessageLimitStrategy> >> >> <subscriptionRecoveryPolicy> >> <lastImageSubscriptionRecoveryPolicy/> >> </subscriptionRecoveryPolicy> >> >> </policyEntry> >> >> </policyEntries> >> </policyMap> >> </destinationPolicy> >> >> Does this feature just not work? Does anyone know? >> >> -Marti DeMore >> >> >> >> -- >> View this message in context: >> http://www.nabble.com/Cannot-get-slow-consumers-to-discard-messages-tp20786422p20786422.html >> Sent from the ActiveMQ - User mailing list archive at Nabble.com. >> > > > -- View this message in context: http://www.nabble.com/Cannot-get-slow-consumers-to-discard-messages-tp20786422p20992296.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
