svn commit: r1341953 - /camel/trunk/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateDiscardOnTimeoutTest.java

[da...@apache.org]

Author: davsclaus
Date: Wed May 23 17:12:50 2012
New Revision: 1341953

URL: http://svn.apache.org/viewvc?rev=1341953&view=rev
Log:
Fixed test on a slower box

Modified:
    camel/trunk/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateDiscardOnTimeoutTest.java

Modified: camel/trunk/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateDiscardOnTimeoutTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateDiscardOnTimeoutTest.java?rev=1341953&r1=1341952&r2=1341953&view=diff
==============================================================================
--- camel/trunk/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateDiscardOnTimeoutTest.java (original)
+++ camel/trunk/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateDiscardOnTimeoutTest.java Wed May 23 17:12:50 2012
@@ -38,8 +38,8 @@ public class JdbcAggregateDiscardOnTimeo
         template.sendBodyAndHeader("direct:start", "A", "id", 123);
         template.sendBodyAndHeader("direct:start", "B", "id", 123);
 
-        // wait 3 seconds
-        Thread.sleep(3000);
+        // wait 4 seconds
+        Thread.sleep(4000);
 
         mock.assertIsSatisfied();
 
@@ -63,9 +63,9 @@ public class JdbcAggregateDiscardOnTimeo
                 from("direct:start")
                         .aggregate(header("id"), new MyAggregationStrategy())
                         .completionSize(3).aggregationRepository(repo)
-                        // use a 3 second timeout
+                        // use a 2 second timeout
                         .completionTimeout(2000)
-                                // and if timeout occurred then just discard the aggregated message
+                        // and if timeout occurred then just discard the aggregated message
                         .discardOnCompletionTimeout()
                         .to("mock:aggregated");
             }