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 2010/07/09 08:03:53 UTC
svn commit: r962423 -
/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/
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");