Return-Path: 
 <dev-return-10138-apmail-activemq-dev-archive=activemq.apache.org@activemq.apache.org>
Delivered-To: apmail-activemq-dev-archive@www.apache.org
Received: (qmail 77976 invoked from network); 9 Apr 2008 18:46:28 -0000
Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2)
  by minotaur.apache.org with SMTP; 9 Apr 2008 18:46:28 -0000
Received: (qmail 13093 invoked by uid 500); 9 Apr 2008 18:46:28 -0000
Delivered-To: apmail-activemq-dev-archive@activemq.apache.org
Received: (qmail 13062 invoked by uid 500); 9 Apr 2008 18:46:28 -0000
Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:dev-help@activemq.apache.org>
List-Unsubscribe: <mailto:dev-unsubscribe@activemq.apache.org>
List-Post: <mailto:dev@activemq.apache.org>
List-Id: <dev.activemq.apache.org>
Reply-To: dev@activemq.apache.org
Delivered-To: mailing list dev@activemq.apache.org
Received: (qmail 12875 invoked by uid 99); 9 Apr 2008 18:46:28 -0000
Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136)
    by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 09 Apr 2008 11:46:27 -0700
X-ASF-Spam-Status: No, hits=-2000.0 required=10.0
	tests=ALL_TRUSTED
X-Spam-Check-By: apache.org
Received: from [140.211.11.140] (HELO brutus.apache.org) (140.211.11.140)
    by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 09 Apr 2008 18:45:46 +0000
Received: from brutus (localhost [127.0.0.1])
	by brutus.apache.org (Postfix) with ESMTP id B6ADD234C0C8
	for <dev@activemq.apache.org>; Wed,  9 Apr 2008 11:43:32 -0700 (PDT)
Message-ID: <855339547.1207766612747.JavaMail.jira@brutus>
Date: Wed, 9 Apr 2008 11:43:32 -0700 (PDT)
From: "Rob Davies (JIRA)" <jira@apache.org>
To: dev@activemq.apache.org
Subject: [jira] Resolved: (AMQ-905) A single JMS Listener is way too slow
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 7bit
X-Virus-Checked: Checked by ClamAV on apache.org


     [ https://issues.apache.org/activemq/browse/AMQ-905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Rob Davies resolved AMQ-905.
----------------------------

    Fix Version/s: 5.1.0
                       (was: 5.2.0)
       Resolution: Fixed

> A single JMS Listener is way too slow
> -------------------------------------
>
>                 Key: AMQ-905
>                 URL: https://issues.apache.org/activemq/browse/AMQ-905
>             Project: ActiveMQ
>          Issue Type: Bug
>    Affects Versions: 4.0.1
>            Reporter: Daniel Aioanei
>            Assignee: Rob Davies
>             Fix For: 5.1.0
>
>         Attachments: activemq.xml
>
>
> I'm using ActiveMQ 4.0.1 with a DerbyDB backend and I have a single JMS listener for a queue with loads of messages. In order to see how many msg/second are processed by a no-op JMS listener, with a single concurrent session, I used the following configuration:
> <?xml version="1.0" encoding="UTF-8"?>
> <!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" 
>     "http://www.springframework.org/dtd/spring-beans.dtd">
> <beans>
>   <!-- START SNIPPET: jca -->
>   <bean id="jencks" class="org.jencks.JCAContainer">
>     <!-- lets use the default configuration of work manager and transaction manager-->
>     <property name="bootstrapContext">
>       <bean class="org.jencks.factory.BootstrapContextFactoryBean">
>         <property name="threadPoolSize" value="200"/>
>       </bean>
>     </property>
>     <!-- the JCA Resource Adapter -->
>     <property name="resourceAdapter">
>       <bean id="activeMQResourceAdapter" class="org.apache.activemq.ra.ActiveMQResourceAdapter">
>         <property name="serverUrl" value="tcp://localhost:61616?wireFormat.cacheEnabled=false&amp;wireFormat.tightEncodingEnabled=false&amp;jms.useAsyncSend=false"/>
>       </bean>
>     </property>
>   </bean>
>   <!-- END SNIPPET: jca -->
>   <!--
>     || an inbound message connector using a stateless, thread safe MessageListener
>     -->
>   <!-- START SNIPPET: inbound -->
>   
>   <bean id="inboundConnectorA" class="org.jencks.JCAConnector">
>     <property name="jcaContainer" ref="jencks" />
>     <!-- subscription details -->
>     <property name="activationSpec">
>       <bean class="org.apache.activemq.ra.ActiveMQActivationSpec">
>         <property name="destination" value="queue/MyQueue"/>
>         <property name="destinationType" value="javax.jms.Queue"/>
>         <property name="acknowledgeMode" value="Auto-acknowledge"/>
>         <property name="useRAManagedTransaction" value="false"/>
>         
> 		<property name="maximumRedeliveries" value="10"/>
> 		<property name="initialRedeliveryDelay" value="1000"/>
> 		<property name="useExponentialBackOff" value="true"/>
> 		<property name="backOffMultiplier" value="5"/>
> 		
>         <property name="maxSessions" value="1"/>
>         <property name="maxMessagesPerSessions" value="1"/>
>       </bean>
>     </property>
>     <property name="ref" value="testOutboundMdp"/>
>   </bean>
> 	<bean id="testOutboundMdp" class="TestOutboundMdp"/>
>   
> </beans>
> The problem is that the consumption speed is 11 msg/second and cpu consumption is about 1-2%. To get almost 100% cpu usage I have to increase threadPoolSize and maximumRedeliveries to 1000 (!) and at that point the consumption speed reaches 142 msg/sec, which is not too impressive either. I'm not sure if it's a Jencks or ActiveMQ issue here.

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.