camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject svn commit: r962423 - /camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/
Date Fri, 09 Jul 2010 06:03:53 GMT
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");



Mime
View raw message