activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Rob Davies <rajdav...@gmail.com>
Subject Re: Cannot get slow consumers to discard messages
Date Tue, 02 Dec 2008 13:52:52 GMT
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.
>


Mime
View raw message