svn commit: r747245 - /camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/queue/version/LoanBroker.java

[ni...@apache.org]

Author: ningjiang
Date: Tue Feb 24 01:05:09 2009
New Revision: 747245

URL: http://svn.apache.org/viewvc?rev=747245&view=rev
Log:
Fixed the build error of camel-example-loan-broker

Modified:
    camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/queue/version/LoanBroker.java

Modified: camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/queue/version/LoanBroker.java
URL: http://svn.apache.org/viewvc/camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/queue/version/LoanBroker.java?rev=747245&r1=747244&r2=747245&view=diff
==============================================================================
--- camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/queue/version/LoanBroker.java (original)
+++ camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/queue/version/LoanBroker.java Tue Feb 24 01:05:09 2009
@@ -85,9 +85,11 @@
 
         // Now we aggregate the response message by using the Constants.PROPERTY_SSN header.
         // The aggregation will be complete when all the three bank responses are received
+        // In Camel 2.0 the we use AGGERATED_SIZE instead of AGGERATED_COUNT as the header 
+        // name of the aggregated message size.
         from("jms:queue:bankReplyQueue")
             .aggregate(header(Constants.PROPERTY_SSN), new BankResponseAggregationStrategy())
-            .completedPredicate(header(Exchange.AGGREGATED_COUNT).isEqualTo(3))
+            .completedPredicate(header(Exchange.AGGREGATED_SIZE).isEqualTo(3))
 
         // Here we do some translation and put the message back to loanReplyQueue
             .process(new Translator()).to("jms:queue:loanReplyQueue");