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 <selvara...@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 <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. > > -- http://blog.garytully.com Open Source Integration http://fusesource.com
