activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Joe Fernandez <joe.fernan...@ttmsolutions.com>
Subject Re: Slow sending of messages
Date Mon, 21 Dec 2009 13:00:05 GMT

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


Mime
View raw message