From users-return-12591-apmail-activemq-users-archive=activemq.apache.org@activemq.apache.org Thu Feb 07 08:25:40 2008
Return-Path: <users-return-12591-apmail-activemq-users-archive=activemq.apache.org@activemq.apache.org>
Delivered-To: apmail-activemq-users-archive@www.apache.org
Received: (qmail 5698 invoked from network); 7 Feb 2008 08:25:40 -0000
Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2)
  by minotaur.apache.org with SMTP; 7 Feb 2008 08:25:40 -0000
Received: (qmail 71935 invoked by uid 500); 7 Feb 2008 08:25:31 -0000
Delivered-To: apmail-activemq-users-archive@activemq.apache.org
Received: (qmail 71910 invoked by uid 500); 7 Feb 2008 08:25:31 -0000
Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:users-help@activemq.apache.org>
List-Unsubscribe: <mailto:users-unsubscribe@activemq.apache.org>
List-Post: <mailto:users@activemq.apache.org>
List-Id: <users.activemq.apache.org>
Reply-To: users@activemq.apache.org
Delivered-To: mailing list users@activemq.apache.org
Received: (qmail 71901 invoked by uid 99); 7 Feb 2008 08:25:31 -0000
Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136)
    by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 07 Feb 2008 00:25:31 -0800
X-ASF-Spam-Status: No, hits=0.2 required=10.0
	tests=SPF_PASS,WHOIS_MYPRIVREG
X-Spam-Check-By: apache.org
Received-SPF: pass (athena.apache.org: domain of rajdavies@gmail.com designates 209.85.146.183 as permitted sender)
Received: from [209.85.146.183] (HELO wa-out-1112.google.com) (209.85.146.183)
    by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 07 Feb 2008 08:25:00 +0000
Received: by wa-out-1112.google.com with SMTP id k22so4015924waf.0
        for <users@activemq.apache.org>; Thu, 07 Feb 2008 00:25:08 -0800 (PST)
DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed;
        d=gmail.com; s=gamma;
        h=domainkey-signature:received:received:message-id:from:to:in-reply-to:content-type:content-transfer-encoding:mime-version:subject:date:references:x-mailer;
        bh=1zWUVHAZPM5oIvkIWawNSS+cTCC/MjZhStMMCQczBR4=;
        b=N+czRdgOuA0x1EqrxDwYye7nPhH0M06/jKA3R+60oQFo5eT0hjG7rgnF1HsP8RO2PTrghRejgkw9kdoQ3PXmrSGSYMsYAm6WCU1Wy8aWqca2hF8l3SZRrjirkjPImsD+Nnad602DKSuucOOlo5NIb6ECvuob88V6QvU4hBZDSxw=
DomainKey-Signature: a=rsa-sha1; c=nofws;
        d=gmail.com; s=gamma;
        h=message-id:from:to:in-reply-to:content-type:content-transfer-encoding:mime-version:subject:date:references:x-mailer;
        b=Fhq7P4Z3Sr/hW1K28wnCTt2JCLmGAIYbqrb2JNjGYVi8uvy8JjkdM89p+Ekc7of4LAowu24gKErnYhnYRfqDvWjINquEuajJRp/6ZCXO7N/d/XLYQ5o5tz+5Wovqx1VShZvf5j8BqIV0wJXf+irojf/I/Ud4r7Bu/NV9bueMrwU=
Received: by 10.115.92.2 with SMTP id u2mr5312804wal.139.1202372707871;
        Thu, 07 Feb 2008 00:25:07 -0800 (PST)
Received: from ?192.168.1.244? ( [86.134.103.250])
        by mx.google.com with ESMTPS id 32sm28377970nfu.7.2008.02.07.00.25.06
        (version=TLSv1/SSLv3 cipher=OTHER);
        Thu, 07 Feb 2008 00:25:07 -0800 (PST)
Message-Id: <DED6227A-802E-4E3E-BBC3-6E0EF2D040BD@gmail.com>
From: Rob Davies <rajdavies@gmail.com>
To: users@activemq.apache.org
In-Reply-To: <15329147.post@talk.nabble.com>
Content-Type: text/plain; charset=US-ASCII; format=flowed; delsp=yes
Content-Transfer-Encoding: 7bit
Mime-Version: 1.0 (Apple Message framework v915)
Subject: Re: OutOfMemoryError in ActiveMQ5.0
Date: Thu, 7 Feb 2008 08:25:04 +0000
References: <15329147.post@talk.nabble.com>
X-Mailer: Apple Mail (2.915)
X-Virus-Checked: Checked by ClamAV on apache.org


On Feb 7, 2008, at 8:17 AM, Tushar Tarkas wrote:

>
> Hi,
>
> I have a spring based solution using activemq. I recently i upgraded
> activemq from 4.1 to 5.0.
>
> What I am observing is, ActiveMQ5.0 gives OutOfMemoryError at stress  
> test
> condition described below. ActiveMQ4.1 whereas, did not fail at the  
> same
> stress level. The configuration used by me is as following.
>
> Jar used: activemq-all-5.0.0.jar
> Configuration File Used:
> <!-- START SNIPPET: example -->
> <beans xmlns="http://activemq.org/config/1.0">
>
>  <!-- Allows us to use system properties as variables in this  
> configuration
> file -->
>  <bean
> class 
> = 
> "org 
> .springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
>
>  <broker useJmx="true">
>
>    <!--  Use the following to set the broker memory limit (in bytes)
>    <memoryManager>
>        <usageManager id="memory-manager" limit="1048576"/>
>    </memoryManager>
>    -->
>
> <!-- memoryUsage>
> 	<limit>20 mb</limit>
> </memoryUsage -->
>
>    <!-- Use the following to configure how ActiveMQ is exposed in JMX
>    <managementContext>
>       <managementContext connectorPort="1099"
> jmxDomainName="org.apache.activemq"/>
>    </managementContext>
>    -->
>
>    <!-- In ActiveMQ 4, you can setup destination policies -->
>    <destinationPolicy>
>      <policyMap><policyEntries>
>
>          <policyEntry topic="FOO.>">
>            <dispatchPolicy>
>              <strictOrderDispatchPolicy />
>            </dispatchPolicy>
>            <subscriptionRecoveryPolicy>
>              <lastImageSubscriptionRecoveryPolicy />
>            </subscriptionRecoveryPolicy>
>          </policyEntry>
>
>      </policyEntries></policyMap>
>    </destinationPolicy>
>
>
>    <persistenceAdapter>
>        <journaledJDBC journalLogFiles="5"
> dataDirectory="${activemq.home}/activemq-data"/>
>      <!-- To use a different datasource, use th following syntax : -->
>      <!--
>      <journaledJDBC journalLogFiles="5" dataDirectory="../activemq- 
> data"
> dataSource="#postgres-ds"/>
>       -->
>    </persistenceAdapter>
>
>    <transportConnectors>
>       <transportConnector name="default" uri="tcp://localhost:61616"
> discoveryUri="multicast://default"/>
>       <transportConnector name="stomp"   uri="stomp://localhost: 
> 61613"/>
>    </transportConnectors>
>
> 	<systemUsage>
> 	            <systemUsage>
> 		            <memoryUsage>
> 	    	            	<memoryUsage limit="5 mb"  
> percentUsageMinDelta="20"/>
> 		            </memoryUsage>
> 		            <tempUsage>
> 	    	            	<tempUsage limit="10 mb"/>
> 		            </tempUsage>
> 		            <storeUsage>
> 	    	            	<storeUsage limit="1 gb" name="foo"/>
> 		            </storeUsage>
> 	            </systemUsage>
> 	    </systemUsage>
>
>    <networkConnectors>
>      <!-- by default just auto discover the other brokers -->
>      <networkConnector name="default" uri="multicast://default"/>
>      <!--
>      <networkConnector name="host1 and host2"
> uri="static://(tcp://host1:61616,tcp://host2:61616)" failover="true"/>
>      -->
>    </networkConnectors>
>
>  </broker>
>
>  <!--  This xbean configuration file supports all the standard  
> spring xml
> configuration options -->
>
>  <!-- Postgres DataSource Sample Setup -->
>  <!--
>  <bean id="postgres-ds" class="org.postgresql.ds.PGPoolingDataSource">
>    <property name="serverName" value="localhost"/>
>    <property name="databaseName" value="activemq"/>
>    <property name="portNumber" value="0"/>
>    <property name="user" value="activemq"/>
>    <property name="password" value="activemq"/>
>    <property name="dataSourceName" value="postgres"/>
>    <property name="initialConnections" value="1"/>
>    <property name="maxConnections" value="10"/>
>  </bean>
>  -->
>
>  <!-- MySql DataSource Sample Setup -->
>  <!--
>  <bean id="mysql-ds" class="org.apache.commons.dbcp.BasicDataSource"
> destroy-method="close">
>    <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
>    <property name="url"
> value="jdbc:mysql://localhost/activemq?relaxAutoCommit=true"/>
>    <property name="username" value="activemq"/>
>    <property name="password" value="activemq"/>
>    <property name="poolPreparedStatements" value="true"/>
>  </bean>
>  -->
>
>  <!-- Embedded Derby DataSource Sample Setup -->
>  <!--
>  <bean id="derby-ds" class="org.apache.derby.jdbc.EmbeddedDataSource">
>    <property name="databaseName" value="derbydb"/>
>    <property name="createDatabase" value="create"/>
>  </bean>
>  -->
>
> </beans>
> <!-- END SNIPPET: example -->
>
>
>
> Load Generated:
> I have created 100 topics and there is 1 subscriber per topic. The  
> topic is
> created at runtime and use all default configurations. There is  
> module which
> publishes messages in loop to generate heavy message load. I am  
> publishing
> 1000 messages/topic. The brokers mode is AUTO_ACKNOWLEDGE.
>
> Results:
> In case of ActiveMQ5.0, I get OutOfMemoryError when 27000 messages are
> published and consumed. The consumer is a do nothing consumer.
>
>
> I have tried configuring broker for system usage but still there is no
> change.
>
> Is there anything which I am missing or doing incorrectly.
>
> ~Tushar
> -- 
> View this message in context: http://www.nabble.com/OutOfMemoryError-in-ActiveMQ5.0-tp15329147s2354p15329147.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>

Try the latest 5.1 snasphot - there have been some problems resolved  
in this area.




cheers,

Rob

http://open.iona.com/ -Enterprise Open Integration
http://rajdavies.blogspot.com/