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 2013/10/03 11:56:01 UTC
[2/2] git commit: Fixed test
Fixed test
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/68700711
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/68700711
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/68700711
Branch: refs/heads/master
Commit: 687007117ac1ef188a16041bd07c92a524f726d3
Parents: 5105d1d
Author: Claus Ibsen <da...@apache.org>
Authored: Thu Oct 3 11:30:21 2013 +0200
Committer: Claus Ibsen <da...@apache.org>
Committed: Thu Oct 3 11:55:54 2013 +0200
----------------------------------------------------------------------
.../processor/aggregator/AggregateCompletionIntervalTest.java | 4 ++--
.../aggregator/SpringAggregateCompletionIntervalTest.xml | 2 +-
2 files changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/68700711/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateCompletionIntervalTest.java
----------------------------------------------------------------------
diff --git a/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateCompletionIntervalTest.java b/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateCompletionIntervalTest.java
index 02b45a9..3859672 100644
--- a/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateCompletionIntervalTest.java
+++ b/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateCompletionIntervalTest.java
@@ -37,7 +37,7 @@ public class AggregateCompletionIntervalTest extends ContextTestSupport {
Thread.sleep(2000);
for (int i = 0; i < 10; i++) {
- template.sendBodyAndHeader("direct:start", "Message " + i, "id", "1");
+ template.sendBodyAndHeader("seda:start", "Message " + i, "id", "1");
}
assertMockEndpointsSatisfied();
@@ -49,7 +49,7 @@ public class AggregateCompletionIntervalTest extends ContextTestSupport {
@Override
public void configure() throws Exception {
// START SNIPPET: e1
- from("direct:start")
+ from("seda:start")
.aggregate(header("id"), new UseLatestAggregationStrategy())
// trigger completion every 5th second
.completionInterval(5000)
http://git-wip-us.apache.org/repos/asf/camel/blob/68700711/components/camel-spring/src/test/resources/org/apache/camel/spring/processor/aggregator/SpringAggregateCompletionIntervalTest.xml
----------------------------------------------------------------------
diff --git a/components/camel-spring/src/test/resources/org/apache/camel/spring/processor/aggregator/SpringAggregateCompletionIntervalTest.xml b/components/camel-spring/src/test/resources/org/apache/camel/spring/processor/aggregator/SpringAggregateCompletionIntervalTest.xml
index ae7468b..343d2f7 100644
--- a/components/camel-spring/src/test/resources/org/apache/camel/spring/processor/aggregator/SpringAggregateCompletionIntervalTest.xml
+++ b/components/camel-spring/src/test/resources/org/apache/camel/spring/processor/aggregator/SpringAggregateCompletionIntervalTest.xml
@@ -25,7 +25,7 @@
<!-- START SNIPPET: e1 -->
<camelContext xmlns="http://camel.apache.org/schema/spring">
<route>
- <from uri="direct:start"/>
+ <from uri="seda:start"/>
<!-- trigger completion of all current aggregated exchanges every 5th second -->
<aggregate strategyRef="aggregatorStrategy" completionInterval="5000">
<correlationExpression>