activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Matthias Wessel (Created) (JIRA)" <j...@apache.org>
Subject [jira] [Created] (AMQ-3664) Not all messages will be consumed when optimizeAcknowledge is true
Date Tue, 17 Jan 2012 09:38:40 GMT
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

        

Mime
View raw message