svn commit: r880655 - /camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsConcurrentConsumersTest.java

[davsclaus]

Author: davsclaus
Date: Mon Nov 16 08:21:09 2009
New Revision: 880655

URL: http://svn.apache.org/viewvc?rev=880655&view=rev
Log:
Fixed test on slower boxes

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

Modified: 
camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsConcurrentConsumersTest.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsConcurrentConsumersTest.java?rev=880655&r1=880654&r2=880655&view=diff
==============================================================================
--- 
camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsConcurrentConsumersTest.java
 (original)
+++ 
camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsConcurrentConsumersTest.java
 Mon Nov 16 08:21:09 2009
@@ -31,6 +31,7 @@
 import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 
 import static org.apache.camel.component.jms.JmsComponent.jmsComponent;
+
 /**
  * Concurrent consumer with JMSReply test.
  */
@@ -40,7 +41,6 @@
     public void testConcurrentConsumersWithReply() throws Exception {
         // latch for the 5 exchanges we expect
         final CountDownLatch latch = new CountDownLatch(5);
-        long start = System.currentTimeMillis();
 
         // setup a task executor to be able send the messages in parallel
         ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
@@ -50,19 +50,22 @@
             final int count = i;
             executor.execute(new Runnable() {
                 public void run() {
-                    // requestbody is InOut pattern and thus we expect a reply 
(JMSReply)
+                    // request body is InOut pattern and thus we expect a 
reply (JMSReply)
                     Object response = template.requestBody("activemq:a", 
"World #" + count);
                     assertEquals("Bye World #" + count, response);
                     latch.countDown();
                 }
             });
         }
+
+        long start = System.currentTimeMillis();
+
         // wait for test completion, timeout after 30 sec to let other unit 
test run to not wait forever
         latch.await(30000L, TimeUnit.MILLISECONDS);
         assertEquals("Latch should be zero", 0, latch.getCount());
 
         long delta = System.currentTimeMillis() - start;
-        assertTrue("Should be faster than 10000 millis, took " + delta + " 
millis", delta < 10000L);
+        assertTrue("Should be faster than 20000 millis, took " + delta + " 
millis", delta < 20000L);
     }
 
     protected CamelContext createCamelContext() throws Exception {
@@ -83,7 +86,7 @@
                 from("activemq:b?concurrentConsumers=3").process(new 
Processor() {
                     public void process(Exchange exchange) throws Exception {
                         String body = exchange.getIn().getBody(String.class);
-                        // sleep a little to simulate heacy work and force 
concurrency processing
+                        // sleep a little to simulate heavy work and force 
concurrency processing
                         Thread.sleep(3000);
                         exchange.getOut().setBody("Bye " + body);
                     }