Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Received-SPF: pass (athena.apache.org: domain of lists@nabble.com designates
 216.139.236.158 as permitted sender)
Message-ID: <18611282.post@talk.nabble.com>
Date: Wed, 23 Jul 2008 06:55:05 -0700 (PDT)
From: buchnerm <markus.buchner@gmx.at>
To: users@activemq.apache.org
Subject: Re: Constant load settings for acticemq.xml
In-Reply-To: <18609147.post@talk.nabble.com>
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit
References: <18609147.post@talk.nabble.com>


 is there nobody who can help??
greetings max

Hi -


buchnerm wrote:
> 
> Hi
> 
> I try to use activemq but I always get some issues:
> 
> I produce a load of 360 messages/sec on the "OIconveyer" Queue
> and read with a camel component from this queue
> 
> first it works fine: 
> write (360 messages/sec) 
> read (400 messages/sec)
> 
> but after a while its getting lesser and lesser till its zero
> 
> and ActiveMQ throws the following error:
> 
> **********************************
> WARN  AMQMessageStore                - Message could not be removed from
> long term store: Java heap space
> java.lang.OutOfMemoryError: Java heap space
> WARN  AMQMessageStore                - Message could not be added to long
> term store: Java heap space
> java.lang.OutOfMemoryError: Java heap space
> WARN  AMQMessageStore                - Message could not be added to long
> term store: Java heap space
> java.lang.OutOfMemoryError: Java heap space
> WARN  AMQMessageStore                - Message could not be removed from
> long term store: Java heap space
> java.lang.OutOfMemoryError: Java heap space
> WARN  AMQMessageStore                - Message could not be added to long
> term store: Java heap space
> java.lang.OutOfMemoryError: Java heap space
> WARN  AMQMessageStore                - Message could not be added to long
> term store: Java heap space
> java.lang.OutOfMemoryError: Java heap space
> Exception in thread "NIO Transport Thread" java.lang.OutOfMemoryError:
> Java heap space
> Exception in thread "InactivityMonitor ReadCheck"
> java.lang.OutOfMemoryError: Java heap space
> WARN  AMQMessageStore                - Message could not be added to long
> term store: Java heap space
> java.lang.OutOfMemoryError: Java heap space
> ERROR Queue                          - Failed to page in more queue
> messages
> java.lang.OutOfMemoryError: Java heap space
> Exception in thread "DefaultMessageListenerContainer-643" Exception in
> thread "ActiveMQ Transport Server Thread Handler: nio://localhost:61616"
> java.lang.OutOfMemoryError: Java heap space
> java.lang.OutOfMemoryError: Java heap space
> **********************************
> 
> I have a really powerful box 32 cpu 16 MB Ram - Sun 
> and the cpu load is at 7 percent
> 
> my activemq configuration is:
> 
> (I added " persistent="true" " to broker tag because I heared that this
> should help something)
> 
> The problem I have that it should never happen that the jms stops taking
> messages - it should store them persistent 
> 
> Please need help!!! 
> 
> 
> **********************************
> root@sunloaner03 # vi activemq.xml
> "activemq.xml" 195 lines, 8456 characters
> <!--
>     Licensed to the Apache Software Foundation (ASF) under one or more
>     contributor license agreements.  See the NOTICE file distributed with
>     this work for additional information regarding copyright ownership.
>     The ASF licenses this file to You under the Apache License, Version
> 2.0
>     (the "License"); you may not use this file except in compliance with
>     the License.  You may obtain a copy of the License at
> 
>     http://www.apache.org/licenses/LICENSE-2.0
> 
>     Unless required by applicable law or agreed to in writing, software
>     distributed under the License is distributed on an "AS IS" BASIS,
>     WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
> implied.
>     See the License for the specific language governing permissions and
>     limitations under the License.
> -->
> <!-- START SNIPPET: example -->
> <beans
>   xmlns="http://www.springframework.org/schema/beans"
>   xmlns:amq="http://activemq.apache.org/schema/core"
>   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
>   xsi:schemaLocation="http://www.springframework.org/schema/beans
> http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
>   http://activemq.apache.org/schema/core
> http://activemq.apache.org/schema/core/activemq-core.xsd
>   http://activemq.apache.org/camel/schema/spring
> http://activemq.apache.org/camel/schema/spring/camel-spring.xsd">
> 
>     <!-- Allows us to use system properties as variables in this
> configuration file -->
>     <bean
> class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
> 
>     <broker xmlns="http://activemq.apache.org/schema/core"
> brokerName="localhost" dataDirectory="${activemq.base}/data"
> persistent="true"
>>
> 
>         <!-- Destination specific policies using destination names or
> wildcards -->
>         <destinationPolicy>
>             <policyMap>
>                 <policyEntries>
>                     <policyEntry queue=">" memoryLimit="1024mb"/>
>                     <policyEntry topic=">" memoryLimit="1024mb">
>                         <dispatchPolicy>
>                             <strictOrderDispatchPolicy/>
>                         </dispatchPolicy>
>                         <subscriptionRecoveryPolicy>
>                             <lastImageSubscriptionRecoveryPolicy/>
>                         </subscriptionRecoveryPolicy>
>                     </policyEntry>
>                 </policyEntries>
>             </policyMap>
>         </destinationPolicy>
> 
>         <!-- Use the following to configure how ActiveMQ is exposed in JMX
> -->
>         <managementContext>
>             <managementContext createConnector="false"/>
>         </managementContext>
> 
>         <!-- The store and forward broker networks ActiveMQ will listen to
> -->
>         <networkConnectors>
>             <!-- by default just auto discover the other brokers -->
>             <networkConnector name="default-nc"
> uri="multicast://default"/>
>             <!-- Example of a static configuration:
>             <networkConnector name="host1 and host2"
> uri="static://(tcp://host1:61616,tcp://host2:61616)"/>
>             -->
>         </networkConnectors>
> 
>         <persistenceAdapter>
>             <amqPersistenceAdapter syncOnWrite="false"
> directory="${activemq.base}/data" maxFileLength="1024mb"/>
>         </persistenceAdapter>
> 
>         <!-- Use the following if you wish to configure the journal with
> JDBC -->
>         <!--
>         <persistenceAdapter>
>             <journaledJDBC dataDirectory="${activemq.base}/data"
> dataSource="#postgres-ds"/>
>         </persistenceAdapter>
>         -->
> 
>         <!-- Or if you want to use pure JDBC without a journal -->
>         <!--
>         <persistenceAdapter>
>             <jdbcPersistenceAdapter dataSource="#postgres-ds"/>
>         </persistenceAdapter>
>         -->
> 
>         <!--  The maximum about of space the broker will use before
> slowing down producers -->
>         <systemUsage>
>             <systemUsage>
>                 <memoryUsage>
>                     <memoryUsage limit="2048 mb"/>
>                 </memoryUsage>
>                 <storeUsage>
>                     <storeUsage limit="10 gb" name="foo"/>
>                 </storeUsage>
>                 <tempUsage>
>                     <tempUsage limit="1000 mb"/>
>                 </tempUsage>
>             </systemUsage>
>         </systemUsage>
> 
> 
>         <!-- The transport connectors ActiveMQ will listen to -->
>         <transportConnectors>
>             <!--<transportConnector name="openwire"
> uri="tcp://localhost:61616" discoveryUri="multicast://default"/> -->
> <transportConnector name="nio" uri="nio://localhost:61616"/>
>             <!-- <transportConnector name="ssl"
> uri="ssl://localhost:61617"/>
> <transportConnector name="nio" uri="nio://localhost:61616"/>
>             <transportConnector name="stomp"
> uri="stomp://localhost:61613"/>
>             <transportConnector name="xmpp" uri="xmpp://localhost:61222"/>
> -->
>         </transportConnectors>
> 
>     </broker>
> 
>     <!--
>     ** Lets deploy some Enterprise Integration Patterns inside the
> ActiveMQ Message Broker
>     ** For more details see
>     **
>     ** http://activemq.apache.org/enterprise-integration-patterns.html
>     -->
>     <camelContext id="camel"
> xmlns="http://activemq.apache.org/camel/schema/spring">
> 
>         <!-- You can use a <package> element for each root package to
> search for Java routes -->
>         <package>org.foo.bar</package>
> 
>         <!-- You can use Spring XML syntax to define the routes here using
> the <route> element -->
>         <route>
>             <from uri="activemq:example.A"/>
>             <to uri="activemq:example.B"/>
>         </route>
>     </camelContext>
> 
> 
>     <!-- Uncomment to create a command agent to respond to message based
> admin commands on the ActiveMQ.Agent topic -->
>     <!--
>     <commandAgent xmlns="http://activemq.apache.org/schema/core"
> brokerUrl="vm://localhost"/>
>     -->
> 
> 
>     <!-- An embedded servlet engine for serving up the Admin console -->
>     <jetty xmlns="http://mortbay.com/schemas/jetty/1.0">
>         <connectors>
>             <nioConnector port="8161"/>
>         </connectors>
> 
>         <handlers>
>             <webAppContext contextPath="/admin"
> resourceBase="${activemq.base}/webapps/admin" logUrlOnStart="true"/>
>             <webAppContext contextPath="/demo"
> resourceBase="${activemq.base}/webapps/demo" logUrlOnStart="true"/>
>             <webAppContext contextPath="/fileserver"
> resourceBase="${activemq.base}/webapps/fileserver" logUrlOnStart="true"/>
>         </handlers>
>     </jetty>
> 
>     <!--  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="maxActive" value="200"/>
>       <property name="poolPreparedStatements" value="true"/>
>     </bean>
>     -->
> 
>     <!-- Oracle DataSource Sample Setup -->
>     <!--
>     <bean id="oracle-ds" class="org.apache.commons.dbcp.BasicDataSource"
> destroy-method="close">
>       <property name="driverClassName"
> value="oracle.jdbc.driver.OracleDriver"/>
>       <property name="url"
> value="jdbc:oracle:thin:@localhost:1521:AMQDB"/>
>       <property name="username" value="scott"/>
>       <property name="password" value="tiger"/>
>       <property name="maxActive" value="200"/>
>       <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 -->
> **********************************
> 
> 
> 

-- 
View this message in context: http://www.nabble.com/Constant-load-settings-for-acticemq.xml-tp18609147p18611282.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.