Author: davsclaus
Date: Fri Jul 9 06:03:52 2010
New Revision: 962423
URL: http://svn.apache.org/viewvc?rev=962423&view=rev
Log:
CAMEL-2927: Fixed examples a bit.
Modified:
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeBatchSizeTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeMultipleCorrelationTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeSizePredicateTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeSizeTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/DefaultAggregatorCollectionTest.java
Modified:
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeBatchSizeTest.java
URL:
http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeBatchSizeTest.java?rev=962423&r1=962422&r2=962423&view=diff
==============================================================================
---
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeBatchSizeTest.java
(original)
+++
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeBatchSizeTest.java
Fri Jul 9 06:03:52 2010
@@ -74,8 +74,9 @@ public class AggregateGroupedExchangeBat
// START SNIPPET: e1
// our route is aggregating from the direct queue and sending
the response to the mock
from("direct:start")
+ .log("Aggregator received ${body}")
// aggregated all use same expression
- .aggregate().constant(true).completionSize(2)
+ .aggregate(constant(true)).completionSize(2)
// wait for 0.5 seconds to aggregate
.completionTimeout(500L)
// group the exchanges so we get one single exchange
containing all the others
Modified:
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeMultipleCorrelationTest.java
URL:
http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeMultipleCorrelationTest.java?rev=962423&r1=962422&r2=962423&view=diff
==============================================================================
---
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeMultipleCorrelationTest.java
(original)
+++
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeMultipleCorrelationTest.java
Fri Jul 9 06:03:52 2010
@@ -78,7 +78,7 @@ public class AggregateGroupedExchangeMul
// our route is aggregating from the direct queue and sending
the response to the mock
from("direct:start")
// aggregate all using the foo header
- .aggregate().header("foo")
+ .aggregate(header("foo"))
// group the exchanges so we get one single exchange
containing all the others
.groupExchanges()
// wait for 1 seconds to aggregate
Modified:
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeSizePredicateTest.java
URL:
http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeSizePredicateTest.java?rev=962423&r1=962422&r2=962423&view=diff
==============================================================================
---
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeSizePredicateTest.java
(original)
+++
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeSizePredicateTest.java
Fri Jul 9 06:03:52 2010
@@ -64,7 +64,7 @@ public class AggregateGroupedExchangeSiz
public void configure() throws Exception {
from("direct:start")
// must use eagerCheckCompletion so we can check the
groupSize header on the incoming exchange
-
.aggregate().constant(true).groupExchanges().eagerCheckCompletion().completionSize(header("groupSize"))
+
.aggregate(constant(true)).groupExchanges().eagerCheckCompletion().completionSize(header("groupSize"))
.to("mock:result")
.end();
}
Modified:
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeSizeTest.java
URL:
http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeSizeTest.java?rev=962423&r1=962422&r2=962423&view=diff
==============================================================================
---
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeSizeTest.java
(original)
+++
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeSizeTest.java
Fri Jul 9 06:03:52 2010
@@ -65,7 +65,7 @@ public class AggregateGroupedExchangeSiz
return new RouteBuilder() {
public void configure() throws Exception {
from("direct:start")
-
.aggregate().constant(true).groupExchanges().completionSize(3)
+
.aggregate(constant(true)).groupExchanges().completionSize(3)
.to("mock:result")
.end();
}
Modified:
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeTest.java
URL:
http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeTest.java?rev=962423&r1=962422&r2=962423&view=diff
==============================================================================
---
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeTest.java
(original)
+++
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateGroupedExchangeTest.java
Fri Jul 9 06:03:52 2010
@@ -66,7 +66,7 @@ public class AggregateGroupedExchangeTes
// 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(constant(true))
// wait for 0.5 seconds to aggregate
.completionTimeout(500L)
// group the exchanges so we get one single exchange
containing all the others
Modified:
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/DefaultAggregatorCollectionTest.java
URL:
http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/DefaultAggregatorCollectionTest.java?rev=962423&r1=962422&r2=962423&view=diff
==============================================================================
---
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/DefaultAggregatorCollectionTest.java
(original)
+++
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/DefaultAggregatorCollectionTest.java
Fri Jul 9 06:03:52 2010
@@ -60,7 +60,7 @@ public class DefaultAggregatorCollection
// aggregated by header id
// as we have not configured more on the aggregator it
will default to aggregate the
// latest exchange only
- .aggregate().header("id").aggregationStrategy(new
UseLatestAggregationStrategy())
+ .aggregate(header("id")).aggregationStrategy(new
UseLatestAggregationStrategy())
// wait for 0.5 seconds to aggregate
.completionTimeout(500L)
.to("mock:result");
