svn commit: r1202227 - /camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSelectorInTest.java

[ja...@apache.org]

Author: janstey
Date: Tue Nov 15 15:04:34 2011
New Revision: 1202227

URL: http://svn.apache.org/viewvc?rev=1202227&view=rev
Log:
fix for JmsSelectorInTest

Modified:
    camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSelectorInTest.java

Modified: camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSelectorInTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSelectorInTest.java?rev=1202227&r1=1202226&r2=1202227&view=diff
==============================================================================
--- camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSelectorInTest.java (original)
+++ camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSelectorInTest.java Tue Nov 15 15:04:34 2011
@@ -18,6 +18,8 @@ package org.apache.camel.component.jms;
 
 import javax.jms.ConnectionFactory;
 
+import org.apache.activemq.ActiveMQConnectionFactory;
+import org.apache.activemq.pool.PooledConnectionFactory;
 import org.apache.camel.CamelContext;
 import org.apache.camel.builder.RouteBuilder;
 import org.apache.camel.component.mock.MockEndpoint;
@@ -47,6 +49,14 @@ public class JmsSelectorInTest extends C
         CamelContext camelContext = super.createCamelContext();
 
         ConnectionFactory connectionFactory = CamelJmsTestHelper.createConnectionFactory();
+        
+        // When using asyncSend, the producers (calls to template.sendBodyAndHeader) will not 
+        // be guaranteed to be in the order we have in the test so we need this set to false.
+        // Another way of guaranteeing order is to use persistent messages or transactions.
+        if (connectionFactory instanceof PooledConnectionFactory) {
+            ActiveMQConnectionFactory amqConnectionFactory = (ActiveMQConnectionFactory) ((PooledConnectionFactory)connectionFactory).getConnectionFactory();
+            amqConnectionFactory.setUseAsyncSend(false);            
+        }
         JmsComponent component = jmsComponentAutoAcknowledge(connectionFactory);
         camelContext.addComponent("activemq", component);
         return camelContext;