not sure how do I check that I only have one producer that enqueues like 10K messages at once and then consumers start to consume (each message is processed in 2-3 minutes by the MDB)
sometimes it reaches 20 consumers, but usually it stabilizes in 10 consumers (everytime one MDB is consuming, I set a flag in the db) [] Leo On Mon, Feb 10, 2014 at 3:45 PM, Romain Manni-Bucau <rmannibu...@gmail.com>wrote: > Seems ok. Are your threads waiting for amq? > Le 10 févr. 2014 18:15, "Leonardo K. Shikida" <shik...@gmail.com> a écrit > : > > > My activemq is this. Limits look pretty high for me. > > > > <!-- 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. --> > > <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.xsd > > http://activemq.apache.org/schema/core > > http://activemq.apache.org/schema/core/activemq-core.xsd";> > > > > > > <broker xmlns="http://activemq.apache.org/schema/core"; > > brokerName="localhost" dataDirectory="${activemq.data}"> > > <persistenceAdapter> > > <jdbcPersistenceAdapter dataSource="#oracle-ds"/> > > </persistenceAdapter> > > > > <systemUsage> > > <systemUsage> > > <memoryUsage> > > <memoryUsage limit="1024 mb" /> > > </memoryUsage> > > <storeUsage> > > <storeUsage limit="500 gb" /> > > </storeUsage> > > <tempUsage> > > <tempUsage limit="500 gb" /> > > </tempUsage> > > </systemUsage> > > </systemUsage> > > > > <transportConnectors> > > <transportConnector name="tcp" uri="tcp://0.0.0.0:61616 > "/> > > </transportConnectors> > > </broker> > > > > <bean id="oracle-ds" > > class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close"> > > <property name="driverClassName" > > value="oracle.jdbc.OracleDriver"/> > > <property name="url" value="jdbc:oracle:thin:@localhost > > :1521:XE"/> > > <property name="username" value="xxx"/> > > <property name="password" value="xxx"/> > > <property name="poolPreparedStatements" value="true"/> > > </bean> > > > > </beans> > > > > > > [] > > > > Leo > > > > > > On Mon, Feb 10, 2014 at 2:42 PM, Romain Manni-Bucau > > <rmannibu...@gmail.com>wrote: > > > > > Hi > > > > > > any specific config in your activemq.xml which could limit it? maybe > > > check through jmx (active it in activemq.xml) you have not a limit > > > set) > > > Romain Manni-Bucau > > > Twitter: @rmannibucau > > > Blog: http://rmannibucau.wordpress.com/ > > > LinkedIn: http://fr.linkedin.com/in/rmannibucau > > > Github: https://github.com/rmannibucau > > > > > > > > > > > > 2014-02-10 17:40 GMT+01:00 Leonardo K. Shikida <shik...@gmail.com>: > > > > Hi > > > > > > > > I was following this to try to push more MDBs do consume from a > single > > > queue > > > > > > > > http://openejb.979440.n4.nabble.com/30-Limit-td981453.html > > > > > > > > I am trying this > > > > > > > > tomee.xml > > > > > > > > <Resource id="Default JMS Resource Adapter" > > > > type="ActiveMQResourceAdapter"> > > > > BrokerXmlConfig = xbean:file:/pathto/activemq.xml > > > > ServerUrl = tcp://0.0.0.0:61616 > > > > threadPoolSize 100 > > > > </Resource> > > > > > > > > <Container id="Foo" type="MESSAGE"> > > > > InstanceLimit 100 > > > > </Container> > > > > > > > > and in the MDB > > > > > > > > (...) > > > > @ActivationConfigProperty( > > > > propertyName = "maxSessions", > > > > propertyValue = "100"), > > > > @ActivationConfigProperty( > > > > propertyName = "maxMessagesPerSessions", > > > > propertyValue = "100") }) > > > > public class MyWorker implements MessageListener { > > > > > > > > After that, my consumers went from 10 (default) to 20, but I'd like > to > > > push > > > > to 100. > > > > > > > > Am I missing something? > > > > > > > > TIA > > > > > > > > Leo > > > > > >
