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");
