activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From SKBuser <>
Subject Why can't I get performance boost while changing persistent activemq messages to non-persistent?
Date Tue, 14 May 2019 04:25:24 GMT
I'm trying to get a higher speed for sending messages via ActiveMQ broker.

The problem is, that I don't get a great perfomence boost. It takes about 2
minutes 40 seconds to send 10000 persistent messages from queue №1 to queue
№2 via my service. And it takes about 2 minutes 20 seconds to send 10000
non-persistent messages. I'm expecting to get at lest x10 speed perfomence
for non-persistent mode. Actually I can get it setting transacted property
to "false":

<property name="transacted" value="false"/>
But this is not an option, I need transacted mode for messages that are

I have configured ActiveMQ like this:

<bean class="org.apache.activemq.ActiveMQConnectionFactory"
        <property name="brokerURL" value="${AMQ.URL}"/>
        <property name="userName" value="${AMQ.USER}"/>
        <property name="password" value="${AMQ.PASSWORD}"/>
    <bean class="org.apache.activemq.pool.PooledConnectionFactory"
        destroy-method="stop" id="jmsConnectionPool" init-method="start">
        <property name="maxConnections" value="10"/>
        <property name="connectionFactory" ref="jmsConnectionFactory"/>
    <bean class="org.apache.camel.component.jms.JmsConfiguration"
        <property name="connectionFactory" ref="jmsConnectionPool"/>
        <property name="concurrentConsumers" value="10"/>
        <property name="preserveMessageQos" value="true"/>
        <property name="transacted" value="true"/>
        <property name="cacheLevelName" value="CACHE_CONSUMER"/>
    <bean class="org.apache.activemq.camel.component.ActiveMQComponent"
        <property name="configuration" ref="jmsConfig"/>
Camel test route:

<route id="SRV.TEST">
       <description>Test route</description>
       <from uri="{{mqName}}:queue:{{}}"/>
       <to uri="{{mqName}}:queue:{{test.out}}"/>
Can anybody help, what am I doing wrong?

Sent from:

View raw message