camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cmoulli...@apache.org
Subject svn commit: r988514 - in /camel/trunk/tests/camel-itest-activemq-highvolume/src/main: java/org/apache/camel/itest/highvolume/Messages.java resources/META-INF/spring/camel-context.xml
Date Tue, 24 Aug 2010 12:46:22 GMT
Author: cmoulliard
Date: Tue Aug 24 12:46:22 2010
New Revision: 988514

URL: http://svn.apache.org/viewvc?rev=988514&view=rev
Log:
Solve camel route error in the uri syntax (<to uri="JmsProducer"/> --> <to ref="JmsProducer"/>

Modified:
    camel/trunk/tests/camel-itest-activemq-highvolume/src/main/java/org/apache/camel/itest/highvolume/Messages.java
    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/java/org/apache/camel/itest/highvolume/Messages.java
URL: http://svn.apache.org/viewvc/camel/trunk/tests/camel-itest-activemq-highvolume/src/main/java/org/apache/camel/itest/highvolume/Messages.java?rev=988514&r1=988513&r2=988514&view=diff
==============================================================================
--- camel/trunk/tests/camel-itest-activemq-highvolume/src/main/java/org/apache/camel/itest/highvolume/Messages.java
(original)
+++ camel/trunk/tests/camel-itest-activemq-highvolume/src/main/java/org/apache/camel/itest/highvolume/Messages.java
Tue Aug 24 12:46:22 2010
@@ -25,7 +25,7 @@ public class Messages {
     
     public void generate(Exchange exchange) {
      	StringBuilder messages = new StringBuilder();
-        for (int i = 1; i < 1000; i++) {
+        for (int i = 1; i < 10000; i++) {
         	messages.append("Test Message: " + i + ",");
         }
         template.sendBody(messages.toString());

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=988514&r1=988513&r2=988514&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 12:46:22 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=1"/>
+	    <endpoint id="JmsQueueConsumer" uri="jmsConsumer:queue:VirtualQueueConsumer.highVolume?concurrentConsumers=10"/>
 	    <endpoint id="Log" uri="log:org.apache.camel.example?level=WARN"/>
 	    
 	    <route id="ProduceMessages" trace="false">
@@ -26,7 +26,7 @@
 			<from ref="Direct"/>
 			<doTry>
 				<to ref="Split"/>
-				<to uri="JmsQueueProducer"/>
+				<to ref="JmsQueueProducer"/>
 				<doCatch>
 					<exception>javax.jms.ResourceAllocationException</exception>
 					<log message=">>>>>> PRODUCER SHOULD BE STOPPED"/>
@@ -36,9 +36,11 @@
 	    
     	<route id="ConsumeMessages" trace="false">
 		    <from ref="JmsQueueConsumer"/>
+		    <!-- 
 		    <delay>
             	<constant>100</constant>
             </delay>
+             -->
 			<to ref="Log"/>
 		</route>
 
@@ -46,12 +48,13 @@
 	
     <!-- *******************************************************************************************
-->
 	
-	<!-- Create an embedded broker -->
+	<!-- THIS TEXT MUST BE COMMENTED WHEN WE DEPLOY THIS BUNDLE ON SMX/KARAF -->
+	<!-- 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>
-	
+    	-->
 	
     <!-- *******************************************************************************************
-->
 
@@ -77,7 +80,7 @@
         <property name="transacted" value="false"/>
     </bean>
     
-    <bean id="jmsProducer" class="org.apache.activemq.camel.component.ActiveMQComponent">
+    <bean id="jmsProducer" class="org.apache.camel.component.jms.JmsComponent">
         <property name="configuration" ref="jmsConfigProducer"/>
     </bean>
     
@@ -97,7 +100,8 @@
         <property name="transacted" value="false"/>
     </bean>
     
-    <bean id="jmsConsumer" class="org.apache.activemq.camel.component.ActiveMQComponent">
+    <!-- org.apache.activemq.camel.component.ActiveMQComponent  -->
+    <bean id="jmsConsumer" class="org.apache.camel.component.jms.JmsComponent">
         <property name="configuration" ref="jmsConfigConsumer"/>
       
     </bean>



Mime
View raw message