Not all messages will be consumed when optimizeAcknowledge is true
------------------------------------------------------------------

                 Key: AMQ-3664
                 URL: https://issues.apache.org/jira/browse/AMQ-3664
             Project: ActiveMQ
          Issue Type: Bug
            Reporter: Matthias Wessel
            Priority: Critical


I make performance test with activemq. When I set optimizeAcknowledge = true I 
get a dramatic performance improvement, but when I shut down the producer the 
consumer does not acknowledge all messages! If I stop the consumer and then I 
start the consumer a second time the consumer recieves messages again and again 
not all messages will be acknoledged in the queue.

I am using camel 2.9.0 to produce and consume the messages.
I am using the consumer Template with asyncSendBody.
The following route is configured in the camelContext:

    <camel:camelContext id="camelContext">
        <camel:template id="producerTemplate"/>
        <camel:consumerTemplate id="consumerTemplate"/>
        <camel:route>
                <camel:from 
uri="jms:queue0?concurrentConsumers=3&amp;maxConcurrentConsumers=10&amp;asyncConsumer=true"/>
                <camel:to uri="beanConsumer"/>
        </camel:route>
    </camel:camelContext>

The config for the ActiveMQComponent:
    <bean id="jms" 
class="org.apache.activemq.camel.component.ActiveMQComponent">
                <property name="connectionFactory">             
                        <bean 
class="org.apache.activemq.pool.PooledConnectionFactory">
                                <property name="connectionFactory">
                                        <bean 
class="org.apache.activemq.spring.ActiveMQConnectionFactory">
                                                <property 
name="optimizeAcknowledge" value="true"/>
                                                <property name="dispatchAsync" 
value="true"/>
                                                <property name="sendAcksAsync" 
value="true"/>
                                                <property name="useAsyncSend" 
value="true"/>
                                                <property name="brokerURL" 
value="nio://138-ham-de:61616"/>                                             
                                                <property 
name="useDedicatedTaskRunner" value="false"/> 
                                </bean> 
                        </property>
                </bean>
        </property>
    </bean>



--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: 
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira

        

Reply via email to