activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Rob Davies <rajdav...@gmail.com>
Subject Re: Constant load settings for acticemq.xml
Date Mon, 28 Jul 2008 06:12:19 GMT

its a little hard to know what exactly is going wrong - could you send  
us a junit test case please ?

cheers,

Rob

On 24 Jul 2008, at 12:02, buchnerm wrote:

>
> Still no answer? Nobody has a clue how to configure activemq - so  
> that it
> doesn't hang up??
>
> greetings max
>
>
> 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-tp18609147p18629623.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>


Mime
View raw message