Author: cmoulliard
Date: Wed Aug 25 08:45:01 2010
New Revision: 988892
URL: http://svn.apache.org/viewvc?rev=988892&view=rev
Log: (empty)
Modified:
camel/trunk/tests/camel-itest-activemq-highvolume/src/main/resources/META-INF/activemq.xml
camel/trunk/tests/camel-itest-activemq-highvolume/src/main/resources/META-INF/spring/camel-context.xml
Modified:
camel/trunk/tests/camel-itest-activemq-highvolume/src/main/resources/META-INF/activemq.xml
URL:
http://svn.apache.org/viewvc/camel/trunk/tests/camel-itest-activemq-highvolume/src/main/resources/META-INF/activemq.xml?rev=988892&r1=988891&r2=988892&view=diff
==============================================================================
---
camel/trunk/tests/camel-itest-activemq-highvolume/src/main/resources/META-INF/activemq.xml
(original)
+++
camel/trunk/tests/camel-itest-activemq-highvolume/src/main/resources/META-INF/activemq.xml
Wed Aug 25 08:45:01 2010
@@ -45,13 +45,20 @@
<destinationPolicy>
<policyMap>
<policyEntries>
- <policyEntry topic=">" producerFlowControl="true"
memoryLimit="1mb">
+
+ <policyEntry topic=">"
+ producerFlowControl="true"
+ memoryLimit="10 mb">
<pendingSubscriberPolicy>
<vmCursor />
</pendingSubscriberPolicy>
</policyEntry>
- <policyEntry queue=">" producerFlowControl="true"
memoryLimit="1mb">
+ <policyEntry queue=">"
+ optimizedDispatch="true"
+ lazyDispatch="false"
+ producerFlowControl="false"
+ memoryLimit="10 mb">
<pendingQueuePolicy>
<vmQueueCursor/>
</pendingQueuePolicy>
@@ -100,6 +107,7 @@
<transportConnectors>
<transportConnector name="vm" uri="vm://0.0.0.0:61615" />
<transportConnector name="tcp" uri="tcp://0.0.0.0:61616" />
+ <transportConnector name="openwire nio"
uri="nio://0.0.0.0:62828?useQueueForAccept=false"/>
</transportConnectors>
</broker>
Modified:
camel/trunk/tests/camel-itest-activemq-highvolume/src/main/resources/META-INF/spring/camel-context.xml
URL:
http://svn.apache.org/viewvc/camel/trunk/tests/camel-itest-activemq-highvolume/src/main/resources/META-INF/spring/camel-context.xml?rev=988892&r1=988891&r2=988892&view=diff
==============================================================================
---
camel/trunk/tests/camel-itest-activemq-highvolume/src/main/resources/META-INF/spring/camel-context.xml
(original)
+++
camel/trunk/tests/camel-itest-activemq-highvolume/src/main/resources/META-INF/spring/camel-context.xml
Wed Aug 25 08:45:01 2010
@@ -15,10 +15,10 @@
<endpoint id="Split" uri="bean:messages?method=split"/>
<endpoint id="GenerateMessages"
uri="bean:messages?method=generate"/>
<endpoint id="JmsQueueProducer" uri="jmsProducer:topic:highVolume"/>
- <endpoint id="JmsQueueConsumer"
uri="jmsConsumer:queue:VirtualQueueConsumer.highVolume?concurrentConsumers=10"/>
+ <endpoint id="JmsQueueConsumer"
uri="jmsConsumer:queue:VirtualQueueConsumer.highVolume?concurrentConsumers=20"/>
<endpoint id="Mock" uri="mock:virtualConsumer"/>
- <!-- <endpoint id="Log"
uri="log:org.apache.camel.example?level=WARN"/> -->
-
+ <endpoint id="Log" uri="log:org.apache.camel.example?level=WARN"/>
+
<route id="ProduceMessages" trace="false">
<from ref="Timer"/>
<to ref="GenerateMessages"/>
@@ -29,7 +29,6 @@
<from ref="Direct"/>
<doTry>
<to ref="Split"/>
- <to ref="JmsQueueProducer"/>
<doCatch>
<exception>javax.jms.ResourceAllocationException</exception>
<log message=">>>>>> PRODUCER
SHOULD BE STOPPED"/>
@@ -45,7 +44,7 @@
<constant>100</constant>
</delay>
-->
- <to ref="Mock"/>
+ <to ref="Log"/>
</route>
</camelContext>
