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");
