Your policyEntry does not disable producer flow control, add. <policyEntry queue=">" memoryLimit="500mb" producerFlowControl="false" />
also there is a VMPendingMessageCursor that will maintain all references in memory. See the end of http://activemq.apache.org/message-cursors.html for details. 2009/12/20 Adrian A <adri...@acta.co.uk> > > Hi Joe > > I have tried lots of configs but this one below is the most simple for > example. > Sending either object messages or map messages. > > Any ideas what the pagedin is referring to? Is there a cursor that > guarantees no disk paging and just memory? > > Running the fuse version. > > Thanks for any help! > > Adrian > > <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 > http://activemq.apache.org/camel/schema/spring > http://activemq.apache.org/camel/schema/spring/camel-spring.xsd";> > > <!-- Allows us to use system properties as variables in this > configuration file --> > <bean > > class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"> > <property name="locations"> > <value>file:${activemq.base}/conf/credentials.properties</value> > </property> > </bean> > > <broker xmlns="http://activemq.apache.org/schema/core"; > brokerName="localhost" dataDirectory="${activemq.base}/data" > advisorySupport="false" persistent="false"> > > <destinationPolicy> > <policyMap> > <policyEntries> > <policyEntry queue=">" memoryLimit="500mb"/> > <policyEntry topic=">" memoryLimit="500mb"> > </policyEntry> > </policyEntries> > </policyMap> > </destinationPolicy> > > <managementContext> > <managementContext createConnector="false"/> > </managementContext> > > <!-- The store and forward broker networks ActiveMQ will listen to > --> > <networkConnectors> > <networkConnector name="default-nc" uri="multicast://default"/> > </networkConnectors> > > <systemUsage> > <systemUsage> > <memoryUsage> > <memoryUsage limit="500 mb"/> > </memoryUsage> > <storeUsage> > <storeUsage limit="1 gb" name="foo"/> > </storeUsage> > <tempUsage> > <tempUsage limit="400 mb"/> > </tempUsage> > </systemUsage> > </systemUsage> > > <transportConnectors> > <transportConnector name="openwire" uri="tcp://0.0.0.0:61616" > discoveryUri="multicast://default"/> > <transportConnector name="stomp" uri="stomp://0.0.0.0:61613"/> > </transportConnectors> > > </broker> > > <jetty xmlns="http://mortbay.com/schemas/jetty/1.0";> > <connectors> > <nioConnector port="8161"/> > </connectors> > > <handlers> > <webAppContext contextPath="/admin" > resourceBase="${activemq.base}/webapps/admin" logUrlOnStart="true"/> > <webAppContext contextPath="/console" > resourceBase="${activemq.base}/webapps/console" logUrlOnStart="true" /> > </handlers> > </jetty> > </beans> > > > > > Joe Fernandez wrote: > > > > Hi, > > > > Can you post your broker's cfg file? > > > > Also, what is the average size of the non-persistent messages that you're > > pushing through the broker? > > > > Joe > > http://www.ttmsolutions.com > > > > -- > View this message in context: > http://old.nabble.com/Slow-sending-of-messages-tp26849964p26867191.html > Sent from the ActiveMQ - User mailing list archive at Nabble.com. > > -- http://blog.garytully.com Open Source Integration http://fusesource.com
