Author: gtully
Date: Mon Aug 29 11:21:44 2011
New Revision: 1162743
URL: http://svn.apache.org/viewvc?rev=1162743&view=rev
Log:
camel spring pool config, match concurrentConsumers to pool maxActive*num routes
Modified:
activemq/trunk/activemq-camel/src/test/resources/org/apache/activemq/camel/transactedconsume.xml
Modified:
activemq/trunk/activemq-camel/src/test/resources/org/apache/activemq/camel/transactedconsume.xml
URL:
http://svn.apache.org/viewvc/activemq/trunk/activemq-camel/src/test/resources/org/apache/activemq/camel/transactedconsume.xml?rev=1162743&r1=1162742&r2=1162743&view=diff
==============================================================================
---
activemq/trunk/activemq-camel/src/test/resources/org/apache/activemq/camel/transactedconsume.xml
(original)
+++
activemq/trunk/activemq-camel/src/test/resources/org/apache/activemq/camel/transactedconsume.xml
Mon Aug 29 11:21:44 2011
@@ -32,8 +32,10 @@
</bean>
<bean id="vhfBatchListenerPooledConnectionFactory"
class="org.apache.activemq.pool.PooledConnectionFactory">
- <property name="maxConnections" value="1"/>
- <property name="maximumActive" value="1"/>
+ <!-- match maxConnections to the number of routes that share the
connection factory -->
+ <property name="maxConnections" value="2"/>
+ <!-- match maximumActive (which is active sessions) to num routes *
concurrentConsumers in the MLC -->
+ <property name="maximumActive" value="20"/>
<property name="connectionFactory"
ref="vhfBatchListenerJMSConnectionFactory"/>
</bean>
@@ -51,6 +53,7 @@
<bean id="vhfBatchListenerJMSConfig"
class="org.apache.camel.component.jms.JmsConfiguration">
<property name="connectionFactory"
ref="vhfBatchListenerPooledConnectionFactory"/>
<property name="transactionManager"
ref="vhfBatchListenerJMSTransactionManager"/>
+ <property name="receiveTimeout" value="20000" />
<property name="transacted" value="true"/>
<property name="concurrentConsumers" value="10"/>
<property name="cacheLevelName" value="CACHE_CONSUMER"/>
@@ -73,11 +76,10 @@
<camelContext xmlns="http://camel.apache.org/schema/spring";>
<route>
<from uri="activemq:queue:scp_transacted"/>
- <!-- transacted /-->
<process ref="connectionLog"/>
</route>
- <!-- marginally better through put with a second route/connection -->
+ <!-- better through put with a second route/connection once shared
pool config matches concurrentConsumers -->
<route>
<from uri="activemq2:queue:scp_transacted"/>
<process ref="connectionLog"/>
