Updated Branches: refs/heads/camel-2.12.x 260f79c2c -> 7066fd532
Fixed test Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/0ec1747e Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/0ec1747e Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/0ec1747e Branch: refs/heads/camel-2.12.x Commit: 0ec1747e13ffa1a8a63ffec902deaf52b62ad377 Parents: 260f79c Author: Claus Ibsen <davscl...@apache.org> Authored: Thu Oct 3 11:30:21 2013 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Thu Oct 3 11:54:32 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/0ec1747e/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/0ec1747e/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>
