Author: davsclaus
Date: Mon Oct 27 05:01:22 2008
New Revision: 708154
URL: http://svn.apache.org/viewvc?rev=708154&view=rev
Log:
Added better wiki documentation for aggregator.
Modified:
activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/AggregatorTest.java
Modified:
activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/AggregatorTest.java
URL:
http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/AggregatorTest.java?rev=708154&r1=708153&r2=708154&view=diff
==============================================================================
---
activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/AggregatorTest.java
(original)
+++
activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/AggregatorTest.java
Mon Oct 27 05:01:22 2008
@@ -84,14 +84,22 @@
protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
+ // disabled due CAMEL-393
+ //from("seda:header").setHeader("visited",
constant(true)).aggregator(header("cheese")).to("mock:result");
+
// START SNIPPET: ex
+ // in this route we aggregate all from direct:state based on
the header id cheese
from("direct:start").aggregator(header("cheese")).to("mock:result");
- //from("seda:header").setHeader("visited",
constant(true)).aggregator(header("cheese")).to("mock:result");
+ // because of a bug in Camel (CAMEL-393) we can not have other
types between from and aggregator
+ // so we must do it as here with two routes. In the fist line
we set the header visited to true
+ // and link it to the 2nd route by sending it to direct:temp...
from("seda:header").setHeader("visited",
constant(true)).to("direct:temp");
-
+ // and here we consume from direct:temp to continue from above
and aggregate
from("direct:temp").aggregator(header("cheese")).to("mock:result");
+ // in this sample we aggreagte using our own startegy with a
completion predicate
+ // stating that the aggregated header is equal to 5.
from("direct:predicate").aggregator(header("cheese"), new
MyAggregationStrategy()).
completedPredicate(header("aggregated").isEqualTo(5)).to("mock:result");
// END SNIPPET: ex
