activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mar1394 <Martha.D.DeM...@jpl.nasa.gov>
Subject Re: Cannot get slow consumers to discard messages
Date Sat, 13 Dec 2008 17:16:26 GMT

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.


Mime
View raw message