You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@camel.apache.org by da...@apache.org on 2009/01/09 08:50:59 UTC

svn commit: r732943 - /activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregatorBatchOptionsTest.java

Author: davsclaus
Date: Thu Jan  8 23:50:59 2009
New Revision: 732943

URL: http://svn.apache.org/viewvc?rev=732943&view=rev
Log:
Fixed failing unit test

Modified:
    activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregatorBatchOptionsTest.java

Modified: activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregatorBatchOptionsTest.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregatorBatchOptionsTest.java?rev=732943&r1=732942&r2=732943&view=diff
==============================================================================
--- activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregatorBatchOptionsTest.java (original)
+++ activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregatorBatchOptionsTest.java Thu Jan  8 23:50:59 2009
@@ -118,6 +118,8 @@
         template.sendBodyAndHeader("direct:start", "Message 2b", "id", "2");
         template.sendBodyAndHeader("direct:start", "Message 1c", "id", "1");
 
+        // need a little sleep between batches
+        Thread.sleep(10);
         // when we sent the next message we have reached the in batch size limit and the current
         // aggregated exchanges will be sent
         template.sendBodyAndHeader("direct:start", "Message 3a", "id", "3");