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 <selvara...@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.
