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 Tue, 17 Nov 2009 15:55:13 GMT

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-ActiveMQextensionstoStomp for
> 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.


Mime
View raw message