Return-Path: 
 <activemq-dev-return-1716-apmail-geronimo-activemq-dev-archive=geronimo.apache.org@geronimo.apache.org>
Delivered-To: apmail-geronimo-activemq-dev-archive@www.apache.org
Received: (qmail 7901 invoked from network); 3 Jul 2006 17:42:38 -0000
Received: from hermes.apache.org (HELO mail.apache.org) (209.237.227.199)
  by minotaur.apache.org with SMTP; 3 Jul 2006 17:42:38 -0000
Received: (qmail 97214 invoked by uid 500); 3 Jul 2006 17:42:37 -0000
Delivered-To: apmail-geronimo-activemq-dev-archive@geronimo.apache.org
Received: (qmail 97069 invoked by uid 500); 3 Jul 2006 17:42:37 -0000
Mailing-List: contact activemq-dev-help@geronimo.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:activemq-dev-help@geronimo.apache.org>
List-Unsubscribe: <mailto:activemq-dev-unsubscribe@geronimo.apache.org>
List-Post: <mailto:activemq-dev@geronimo.apache.org>
List-Id: <activemq-dev.geronimo.apache.org>
Reply-To: activemq-dev@geronimo.apache.org
Delivered-To: mailing list activemq-dev@geronimo.apache.org
Received: (qmail 96951 invoked by uid 99); 3 Jul 2006 17:42:36 -0000
Received: from asf.osuosl.org (HELO asf.osuosl.org) (140.211.166.49)
    by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 03 Jul 2006 10:42:36 -0700
X-ASF-Spam-Status: No, hits=0.0 required=10.0
	tests=
X-Spam-Check-By: apache.org
Received: from [209.237.227.198] (HELO brutus.apache.org) (209.237.227.198)
    by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 03 Jul 2006 10:42:35 -0700
Received: from brutus (localhost [127.0.0.1])
	by brutus.apache.org (Postfix) with ESMTP id F00974103AA
	for <activemq-dev@geronimo.apache.org>; Mon,  3 Jul 2006 17:40:51 +0000 (GMT)
Message-ID: <21393897.1151948451980.JavaMail.jira@brutus>
Date: Mon, 3 Jul 2006 17:40:51 +0000 (GMT+00:00)
From: "james strachan (JIRA)" <jira@apache.org>
To: activemq-dev@geronimo.apache.org
Subject: [jira] Resolved: (AMQ-391) message consumption is too slow, only
 40/s
MIME-Version: 1.0
Content-Type: text/plain; charset=ISO-8859-1
Content-Transfer-Encoding: 7bit
X-Virus-Checked: Checked by ClamAV on apache.org
X-Spam-Rating: minotaur.apache.org 1.6.2 0/1000/N

     [ https://issues.apache.org/activemq/browse/AMQ-391?page=all ]
     
james strachan resolved AMQ-391:
--------------------------------

    Fix Version: 4.0.1
     Resolution: Fixed

This should be fixed in 4.0.1 now. If its not let us know and we can reopen the issue

> message consumption is too slow, only 40/s
> ------------------------------------------
>
>          Key: AMQ-391
>          URL: https://issues.apache.org/activemq/browse/AMQ-391
>      Project: ActiveMQ
>         Type: Improvement

>     Versions: 3.1
>  Environment: java version "1.5.0_05", Windows XP, Pentium IV 2.6 GHz, 1 Gb memory
>     Reporter: Daniel Aioanei
>      Fix For: 4.0.1

>
>
> For this test I used text messages  with two Long properties, two String properties and one text message, all of them with "normal" sizes. The text message is 80 characters long, while the String properties have 12 characters. I'm using the following activemq configuration:
> <?xml version="1.0" encoding="UTF-8"?>
> <!DOCTYPE beans PUBLIC  "-//ACTIVEMQ//DTD//EN" "http://activemq.org/dtd/activemq.dtd">
> <beans>
>   
>   <!-- ==================================================================== -->
>   <!-- ActiveMQ Broker Configuration -->
>   <!-- ==================================================================== -->
>   <broker>
>     <connector>
>       <tcpServerTransport uri="tcp://localhost:61616" backlog="1000" useAsyncSend="false" maxOutstandingMessages="50"/>
>     </connector>
>     <persistence>
>       <cachePersistence>
>         <journalPersistence directory="../var/journal">
>           <jdbcPersistence dataSourceRef="derby-ds"/>
>         </journalPersistence>
>       </cachePersistence>
>     </persistence>
>         <redeliveryPolicy maximumRetryCount="416" backOffMode="true" backOffIncreaseRate="1" initialRedeliveryTimeout="1000"/>
>   </broker>
>   <!-- ==================================================================== -->
>   <!-- JDBC DataSource Configurations -->
>   <!-- ==================================================================== -->
>   <!-- The Derby Datasource that will be used by the Broker -->
>   <bean id="derby-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
>     <property name="driverClassName">
>       <value>org.apache.derby.jdbc.EmbeddedDriver</value>
>     </property>
>     <property name="url">
>       <!-- Use a URL like 'jdbc:hsqldb:hsql://localhost:9001' if you want to connect to a remote hsqldb -->
>       <value>jdbc:derby:derbydb;create=true</value>
>     </property>
>     <property name="username">
>       <value></value>
>     </property>
>     <property name="password">
>       <value></value>
>     </property>
>     <property name="poolPreparedStatements">
>       <value>true</value>
>     </property>
>   </bean>
> </beans>
> where activemq runs in its own jvm. After I produced about 1000 messages with a producer, I shut it down and then start a consumer jvm. Unfortunately it can only  consume about 40 msg/second while I'd like to get about 400/s. The consumer is configured like this:
> <?xml version="1.0" encoding="UTF-8"?>
> <!-- START SNIPPET: spring -->
> <!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="25"/>
>       </bean>
>     </property>
>     <!-- the JCA Resource Adapter -->
>     <property name="resourceAdapter">
>       <bean id="activeMQResourceAdapter" class="org.activemq.ra.ActiveMQResourceAdapter">
>         <property name="serverUrl" value="reliable:tcp://localhost:61616?asyncSend=false&amp;copyMessageOnSend=false&amp;disableTimeStampsByDefault=true&amp;doMessageCompression=false&amp;doMessageFragmentation=false&amp;prepareMessageBodyOnSend=false&amp;cachingEnabled=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.activemq.ra.ActiveMQActivationSpec">
>         <property name="destination" value="InboundQueue"/>
>         <property name="destinationType" value="javax.jms.Queue"/>
>       </bean>
>     </property>
>     <property name="ref" value="echoBean"/>
>   </bean>
>   <bean id="echoBean" class="com.foo.bar.Mdp" singleton="true"/>
>   <!-- END SNIPPET: inbound -->
> </beans>
> Mdp only reads the properties and nothing more. I tried varying threadPoolSize from 25 to 250 to no avail. I think 40 msg/second is too slow in this configuration.

-- 
This message is automatically generated by JIRA.
-
If you think it was sent incorrectly contact one of the administrators:
   https://issues.apache.org/activemq/secure/Administrators.jspa
-
For more information on JIRA, see:
   http://www.atlassian.com/software/jira