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 2011/01/21 10:27:05 UTC
svn commit: r1061703 -
/camel/trunk/components/camel-hawtdb/src/test/java/org/apache/camel/component/hawtdb/HawtDBAggregateLoadAndRecoverTest.java
Author: davsclaus
Date: Fri Jan 21 09:27:04 2011
New Revision: 1061703
URL: http://svn.apache.org/viewvc?rev=1061703&view=rev
Log:
Fixed test.
Modified:
camel/trunk/components/camel-hawtdb/src/test/java/org/apache/camel/component/hawtdb/HawtDBAggregateLoadAndRecoverTest.java
Modified: camel/trunk/components/camel-hawtdb/src/test/java/org/apache/camel/component/hawtdb/HawtDBAggregateLoadAndRecoverTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-hawtdb/src/test/java/org/apache/camel/component/hawtdb/HawtDBAggregateLoadAndRecoverTest.java?rev=1061703&r1=1061702&r2=1061703&view=diff
==============================================================================
--- camel/trunk/components/camel-hawtdb/src/test/java/org/apache/camel/component/hawtdb/HawtDBAggregateLoadAndRecoverTest.java (original)
+++ camel/trunk/components/camel-hawtdb/src/test/java/org/apache/camel/component/hawtdb/HawtDBAggregateLoadAndRecoverTest.java Fri Jan 21 09:27:04 2011
@@ -61,9 +61,9 @@ public class HawtDBAggregateLoadAndRecov
if (LOG.isDebugEnabled()) {
LOG.debug("Sending " + value + " with id " + id);
}
- template.sendBodyAndHeaders("seda:start?size=" + SIZE, value, headers);
+ template.sendBodyAndHeaders("seda:start", value, headers);
// simulate a little delay
- Thread.sleep(3);
+ Thread.sleep(5);
}
LOG.info("Sending all " + SIZE + " message done. Now waiting for aggregation to complete.");
@@ -87,6 +87,8 @@ public class HawtDBAggregateLoadAndRecov
public void configure() throws Exception {
HawtDBAggregationRepository repo = new HawtDBAggregationRepository("repo1", "target/data/hawtdb.dat");
repo.setUseRecovery(true);
+ // for faster unit testing
+ repo.setRecoveryInterval(500);
from("seda:start?size=" + SIZE)
.to("log:input?groupSize=500")