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 2012/11/10 11:57:15 UTC
svn commit: r1407752 - in /camel/trunk:
camel-core/src/test/java/org/apache/camel/processor/aggregator/
components/camel-spring/src/test/java/org/apache/camel/spring/processor/aggregator/
components/camel-spring/src/test/resources/org/apache/camel/spri...
Author: davsclaus
Date: Sat Nov 10 10:57:13 2012
New Revision: 1407752
URL: http://svn.apache.org/viewvc?rev=1407752&view=rev
Log:
Fixed test
Modified:
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateDiscardOnTimeoutTest.java
camel/trunk/components/camel-spring/src/test/java/org/apache/camel/spring/processor/aggregator/SpringAggregateDiscardOnTimeoutTest.java
camel/trunk/components/camel-spring/src/test/resources/org/apache/camel/spring/processor/aggregator/SpringAggregateDiscardOnTimeoutTest.xml
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateDiscardOnTimeoutTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateDiscardOnTimeoutTest.java?rev=1407752&r1=1407751&r2=1407752&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateDiscardOnTimeoutTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateDiscardOnTimeoutTest.java Sat Nov 10 10:57:13 2012
@@ -35,8 +35,8 @@ public class AggregateDiscardOnTimeoutTe
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();
@@ -61,7 +61,7 @@ public class AggregateDiscardOnTimeoutTe
from("direct:start")
.aggregate(header("id"), new BodyInAggregatingStrategy())
.completionSize(3)
- // use a 3 second timeout
+ // use a 2 second timeout
.completionTimeout(2000)
// and if timeout occurred then just discard the aggregated message
.discardOnCompletionTimeout()
Modified: camel/trunk/components/camel-spring/src/test/java/org/apache/camel/spring/processor/aggregator/SpringAggregateDiscardOnTimeoutTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-spring/src/test/java/org/apache/camel/spring/processor/aggregator/SpringAggregateDiscardOnTimeoutTest.java?rev=1407752&r1=1407751&r2=1407752&view=diff
==============================================================================
--- camel/trunk/components/camel-spring/src/test/java/org/apache/camel/spring/processor/aggregator/SpringAggregateDiscardOnTimeoutTest.java (original)
+++ camel/trunk/components/camel-spring/src/test/java/org/apache/camel/spring/processor/aggregator/SpringAggregateDiscardOnTimeoutTest.java Sat Nov 10 10:57:13 2012
@@ -27,7 +27,7 @@ import static org.apache.camel.spring.pr
public class SpringAggregateDiscardOnTimeoutTest extends AggregateDiscardOnTimeoutTest {
protected CamelContext createCamelContext() throws Exception {
- return createSpringCamelContext(this, "org/apache/camel/spring/processor/aggregator/SpringAggregateSimpleTimeoutTest.xml");
+ return createSpringCamelContext(this, "org/apache/camel/spring/processor/aggregator/SpringAggregateDiscardOnTimeoutTest.xml");
}
}
Modified: camel/trunk/components/camel-spring/src/test/resources/org/apache/camel/spring/processor/aggregator/SpringAggregateDiscardOnTimeoutTest.xml
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-spring/src/test/resources/org/apache/camel/spring/processor/aggregator/SpringAggregateDiscardOnTimeoutTest.xml?rev=1407752&r1=1407751&r2=1407752&view=diff
==============================================================================
--- camel/trunk/components/camel-spring/src/test/resources/org/apache/camel/spring/processor/aggregator/SpringAggregateDiscardOnTimeoutTest.xml (original)
+++ camel/trunk/components/camel-spring/src/test/resources/org/apache/camel/spring/processor/aggregator/SpringAggregateDiscardOnTimeoutTest.xml Sat Nov 10 10:57:13 2012
@@ -26,7 +26,7 @@
<camelContext xmlns="http://camel.apache.org/schema/spring">
<route>
<from uri="direct:start"/>
- <aggregate strategyRef="aggregatorStrategy" completionTimeout="3000" discardOnCompletionTimeout="true">
+ <aggregate strategyRef="aggregatorStrategy" completionTimeout="2000" discardOnCompletionTimeout="true">
<correlationExpression>
<simple>header.id</simple>
</correlationExpression>