activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gary Tully <gary.tu...@gmail.com>
Subject Re: PrefetchSize of Non-Durable topic not able to change
Date Tue, 17 Nov 2009 18:50:03 GMT
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

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message