Re: Cannot get slow consumers to discard messages

[Rob Davies]

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.