camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cmoulli...@apache.org
Subject svn commit: r988577 - in /camel/trunk/tests/camel-itest-activemq-highvolume: pom.xml src/main/resources/META-INF/activemq.xml src/main/resources/META-INF/spring/camel-context.xml
Date Tue, 24 Aug 2010 14:48:21 GMT
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  -->



Mime
View raw message