One other thing you might want to also do is yank persistent=false out of your broker element and instead set the message delivery mode at the message or session level. In my testing, setting persistent=false precludes the broker from creating the message store and thus non-persistent messages will not overflow into the temp store if and when the queue fills up.
Joe Gary Tully wrote: > > 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 > > -- View this message in context: http://old.nabble.com/Slow-sending-of-messages-tp26849964p26873675.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
