Author: cmoulliard
Date: Tue Aug 24 14:48:21 2010
New Revision: 988577
URL: http://svn.apache.org/viewvc?rev=988577&view=rev
Log: (empty)
Modified:
camel/trunk/tests/camel-itest-activemq-highvolume/pom.xml
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/pom.xml
URL:
http://svn.apache.org/viewvc/camel/trunk/tests/camel-itest-activemq-highvolume/pom.xml?rev=988577&r1=988576&r2=988577&view=diff
==============================================================================
--- camel/trunk/tests/camel-itest-activemq-highvolume/pom.xml (original)
+++ camel/trunk/tests/camel-itest-activemq-highvolume/pom.xml Tue Aug 24
14:48:21 2010
@@ -25,7 +25,6 @@
<groupId>org.apache.camel</groupId>
<artifactId>camel-parent</artifactId>
<version>2.5-SNAPSHOT</version>
- <!-- <version>2.4.0</version> -->
</parent>
<artifactId>camel-itest-activemq-highvolume</artifactId>
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=988577&r1=988576&r2=988577&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
Tue Aug 24 14:48:21 2010
@@ -14,15 +14,6 @@
See the License for the specific language governing permissions and
limitations under the License.
-->
-<!--
-<beans
- xmlns="http://www.springframework.org/schema/beans";
- 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-5.3.0.xsd";>
--->
<beans
xmlns="http://www.springframework.org/schema/beans";
xmlns:amq="http://activemq.apache.org/schema/core";
@@ -40,7 +31,7 @@
brokerName="brokerHighVolume"
persistent="false"
useJmx="true"
- enableStatistics="true"
+ enableStatistics="false"
advisorySupport="false">
<destinationInterceptors>
@@ -107,6 +98,7 @@
http://activemq.apache.org/configuring-transports.html
-->
<transportConnectors>
+ <transportConnector name="vm" uri="vm://0.0.0.0:61615" />
<transportConnector name="tcp" uri="tcp://0.0.0.0:61616" />
</transportConnectors>
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=988577&r1=988576&r2=988577&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
Tue Aug 24 14:48:21 2010
@@ -14,7 +14,7 @@
<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"/>
<endpoint id="Log" uri="log:org.apache.camel.example?level=WARN"/>
<route id="ProduceMessages" trace="false">
@@ -40,7 +40,7 @@
<delay>
<constant>100</constant>
</delay>
- -->
+ -->
<to ref="Log"/>
</route>
@@ -49,12 +49,12 @@
<!--
*******************************************************************************************
-->
<!-- THIS TEXT MUST BE COMMENTED WHEN WE DEPLOY THIS BUNDLE ON
SMX/KARAF -->
- <!-- Create an embedded broker
+ <!-- Create an embedded broker -->
<bean id="broker" class="org.apache.activemq.xbean.BrokerFactoryBean">
<property name="config" value="classpath:META-INF/activemq.xml" />
<property name="start" value="true" />
</bean>
- -->
+
<!--
*******************************************************************************************
-->
@@ -63,9 +63,12 @@
and connection pool
-->
- <!-- Connection for the client producing -->
+ <!-- Connection for the client PRODUCING -->
<bean id="jmsConnectionFactoryProducer"
class="org.apache.activemq.ActiveMQConnectionFactory">
- <property name="brokerURL" value="vm://localhost:61616" />
+ <property name="brokerURL" value="vm://localhost:61615" />
+ <property name="objectMessageSerializationDefered" value="true"
/>
+ <property name="optimizeAcknowledge" value="true" />
+ <!-- <property name="useAsyncSend" value="true" /> -->
</bean>
<bean id="pooledConnectionFactory"
class="org.apache.activemq.pool.PooledConnectionFactory">
@@ -86,18 +89,25 @@
<!--
*******************************************************************************************
-->
<!-- Config used to consume the messages
- Transport layer is different tcp:// instead of vm://
+ Transport layer is different tcp:// instead of vm://
jms.prefetchPolicy.queuePrefetch=1
+
and not connection pool is used -->
- <!-- Connection for the client consuming -->
+ <!-- Connection for the client CONSUMING -->
<bean id="jmsConnectionFactoryConsumer"
class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://localhost:61616" />
+ <property name="objectMessageSerializationDefered" value="true" />
+ <property name="optimizeAcknowledge" value="true" />
+ <property name="optimizedMessageDispatch" value="true"/>
+ <property name="dispatchAsync" value="true"/>
</bean>
<!-- Use simple connection factory to consume messages -->
<bean id="jmsConfigConsumer"
class="org.apache.camel.component.jms.JmsConfiguration">
<property name="connectionFactory" ref="jmsConnectionFactoryConsumer"/>
<property name="transacted" value="false"/>
+ <!-- <property name="acknowledgementModeName"
value="DUPS_OK_ACKNOWLEDGE" /> -->
+ <property name="concurrentConsumers" value="10" />
</bean>
<!-- org.apache.activemq.camel.component.ActiveMQComponent -->
