Modified AggregateGroupedExchangeTest replacing deprecated groupExchanges() method.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/f81f9da4 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/f81f9da4 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/f81f9da4 Branch: refs/heads/master Commit: f81f9da47131a266cc4a16df51090c565bfa9cdc Parents: fd57cfc Author: 1984shekhar <shekhar.cs...@yahoo.co.in> Authored: Thu Jun 9 18:02:57 2016 +0530 Committer: Claus Ibsen <davscl...@apache.org> Committed: Fri Jun 10 08:40:51 2016 +0200 ---------------------------------------------------------------------- .../processor/aggregator/AggregateGroupedExchangeTest.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/f81f9da4/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeTest.java ---------------------------------------------------------------------- diff --git a/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeTest.java b/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeTest.java index 4628462..b055197 100644 --- a/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeTest.java +++ b/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeTest.java @@ -22,6 +22,7 @@ import org.apache.camel.ContextTestSupport; import org.apache.camel.Exchange; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.mock.MockEndpoint; +import org.apache.camel.processor.aggregate.GroupedExchangeAggregationStrategy; /** * Unit test for aggregate grouped exchanges. @@ -65,12 +66,10 @@ public class AggregateGroupedExchangeTest extends ContextTestSupport { // START SNIPPET: e1 // our route is aggregating from the direct queue and sending the response to the mock from("direct:start") - // aggregate all using same expression - .aggregate(constant(true)) + // aggregate all using same expression and group the exchanges so we get one single exchange containing all the others + .aggregate(new GroupedExchangeAggregationStrategy()).constant(true) // wait for 0.5 seconds to aggregate .completionTimeout(500L) - // group the exchanges so we get one single exchange containing all the others - .groupExchanges() .to("mock:result"); // END SNIPPET: e1 }