activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From SelvarajAM <selvara...@hcl.in>
Subject Re: PrefetchSize of Non-Durable topic not able to change
Date Wed, 18 Nov 2009 09:22:56 GMT

Thank you very much for your replies. 
Now i am able to set the prefetch attribute.

The problem was, i was trying to set it from the server side but actually it
must be set in client/consumer side. 

I downloaded the STOMP AS3 source code and found the following way to set
it.

var header:SubscribeHeaders = new SubscribeHeaders();
header.amqPrefetchSize="0";
header.amqDispatchAsync="true";
header.amqMaximumPendingMessageLimit="50";	

Stomp.connect(serverName, 8084);
Stomp.subscribe(destination,header);

thank you.


Gary Tully wrote:
> 
> there are prefetch attributes in the PolicyEntry that goes in
> destinationPolicy. It is only in effect if the no consumer override is
> specified.
> What you want is topicPrefetch.
> <policyEntry topic=">" topicPrefetch="100" />
> 
> See all the attributes of PolicyEntry in the src:
> http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java?view=markup
> 
> 
> 
> 2009/11/17 SelvarajAM <selvarajam@hcl.in>
> 
>>
>> Thanks for your reply.
>> I did use stomp extensions but still unable to set the prefetch size.
>>
>> Below is the code i used.
>>
>> connection = new StompConnection();
>> connection.open("0.0.0.0", 8084);
>> connection.connect("test", "test");
>>
>> HashMap<String, String> header = new HashMap<String, String>();
>> header.put("activemq.prefetchSize", "100");
>>
>> connection.send("/topic/a", message,null,header);
>>
>>
>> Is there any attribute for prefetch in   <destinationPolicy>
>> configuartion??
>>
>> Appreciate your help.
>>
>>
>>
>> Dejan Bosanac wrote:
>> >
>> > Hi,
>> >
>> > try setting prefetch size on your consumer using activemq.prefetchSize
>> > header. See
>> >
>> http://activemq.apache.org/stomp.html#Stomp-ActiveMQextensionstoStompfor
>> > more details
>> >
>> > Cheers
>> > --
>> > Dejan Bosanac - http://twitter.com/dejanb
>> >
>> > Open Source Integration - http://fusesource.com/
>> > ActiveMQ in Action - http://www.manning.com/snyder/
>> > Blog - http://www.nighttale.net
>> >
>> >
>> > On Tue, Nov 17, 2009 at 1:12 PM, SelvarajAM <selvarajam@hcl.in> wrote:
>> >
>> >>
>> >> I am using Activemq 5.3, Flex Client  and stomp protocol for
>> >> communication.
>> >>
>> >> I send Non-Persisent messages to Non-Durable topic.
>> >>
>> >> I want to change the PrefetchSize of the Subscribers/Consumers.
>> JConsole
>> >> shows the PrefetchSize as 1000 always, though the document says the
>> >> default
>> >> value as Short.MAX_VALUE -1
>> >>
>> >> I have also tried all the configuration mentioned in the below link,
>> but
>> >> didnt help.
>> >> http://activemq.apache.org/what-is-the-prefetch-limit-for.html
>> >>
>> >> My XML configuration is as follows
>> >>
>> >> <beans
>> >>  xmlns="http://www.springframework.org/schema/beans"
>> >>  xmlns:amq="http://activemq.apache.org/schema/core"
>> >>  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
>> >>  xsi:schemaLocation="http://www.springframework.org/schema/beans
>> >> http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
>> >>  http://activemq.apache.org/schema/core
>> >> http://activemq.apache.org/schema/core/activemq-core.xsd">
>> >>
>> >> <broker xmlns="http://activemq.apache.org/schema/core"
>> persistent="false"
>> >> useJmx="true"  brokerName="PRI" >
>> >> <transportConnectors>
>> >>        <transportConnector name="StompNio"
>> >> uri="stomp://0.0.0.0:8084?consumer.prefetchSize=1015"/>
>> >>        <transportConnector name="Nio"
>> >> uri="nio://0.0.0.0:8086?consumer.prefetchSize=1015"/>
>> >>        <transportConnector name="Tcp"
>> >> uri="tcp://0.0.0.0:8087?consumer.prefetchSize=1015"/>
>> >> </transportConnectors>
>> >> </broker>
>> >> </beans>
>> >>
>> >> Kindly help on this.
>> >>
>> >> Jconsole screen shot is attached
>> >> http://old.nabble.com/file/p26388916/Prefetch.jpg
>> >> --
>> >> View this message in context:
>> >>
>> http://old.nabble.com/PrefetchSize-of-Non-Durable-topic-not-able-to-change-tp26388916p26388916.html
>> >> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>> >>
>> >>
>> >
>> >
>> > -----
>> > Dejan Bosanac
>> >
>> > Open Source Integration - http://fusesource.com/
>> > ActiveMQ in Action - http://www.manning.com/snyder/
>> > Blog - http://www.nighttale.net
>> >
>>
>> --
>> View this message in context:
>> http://old.nabble.com/PrefetchSize-of-Non-Durable-topic-not-able-to-change-tp26388916p26392358.html
>> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>>
>>
> 
> 
> -- 
> http://blog.garytully.com
> 
> Open Source Integration
> http://fusesource.com
> 
> 

-- 
View this message in context: http://old.nabble.com/PrefetchSize-of-Non-Durable-topic-not-able-to-change-tp26388916p26404694.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message