Author: janstey
Date: Thu Dec 18 07:12:43 2008
New Revision: 727738
URL: http://svn.apache.org/viewvc?rev=727738&view=rev
Log:
Wording changes
Modified:
activemq/camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/queue/version/LoanBroker.java
activemq/camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/LoanBroker.java
Modified:
activemq/camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/queue/version/LoanBroker.java
URL:
http://svn.apache.org/viewvc/activemq/camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/queue/version/LoanBroker.java?rev=727738&r1=727737&r2=727738&view=diff
==============================================================================
---
activemq/camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/queue/version/LoanBroker.java
(original)
+++
activemq/camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/queue/version/LoanBroker.java
Thu Dec 18 07:12:43 2008
@@ -75,7 +75,7 @@
// Now we can let the CreditAgency process the request, then the
message will be put into creditResponseQueue
from("jms:queue:creditRequestQueue").process(new
CreditAgency()).to("jms:queue:creditResponseQueue");
- // Here we use the multicast pattern to send the message to three
different bank queue
+ // Here we use the multicast pattern to send the message to three
different bank queues
from("jms:queue:creditResponseQueue").multicast().to("jms:queue:bank1",
"jms:queue:bank2", "jms:queue:bank3");
// Each bank processor will process the message and put the response
message into the bankReplyQueue
@@ -83,8 +83,8 @@
from("jms:queue:bank2").process(new
Bank("bank2")).to("jms:queue:bankReplyQueue");
from("jms:queue:bank3").process(new
Bank("bank3")).to("jms:queue:bankReplyQueue");
- // Now we aggregating the response message by using the
Constants.PROPERTY_SSN header
- // The aggregation will completed when all the three bank responses
are received
+ // 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
from("jms:queue:bankReplyQueue")
.aggregate(header(Constants.PROPERTY_SSN), new
BankResponseAggregationStrategy())
.completedPredicate(header(Exchange.AGGREGATED_COUNT).isEqualTo(3))
@@ -99,7 +99,7 @@
from("jms:queue2:parallelLoanRequestQueue").process(new CreditAgency())
// Set the aggregation strategy for aggregating the out message
.multicast(new
BankResponseAggregationStrategy().setAggregatingOutMessage(true))
- // Send out the request the below three different banks
parallelly
+ // Send out the request to three different banks in parallel
.setParallelProcessing(true).to("jms:queue2:bank1",
"jms:queue2:bank2", "jms:queue2:bank3");
// Each bank processor will process the message and put the response
message back
Modified:
activemq/camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/LoanBroker.java
URL:
http://svn.apache.org/viewvc/activemq/camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/LoanBroker.java?rev=727738&r1=727737&r2=727738&view=diff
==============================================================================
---
activemq/camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/LoanBroker.java
(original)
+++
activemq/camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/LoanBroker.java
Thu Dec 18 07:12:43 2008
@@ -86,16 +86,16 @@
.process(new CreditScoreProcessor(Constants.CREDITAGENCY_ADDRESS))
// Set the aggregation strategy on the multicast pattern
.multicast(new BankResponseAggregationStrategy())
- // Send out the request the below three different banks
sequentially
+ // Send out the request to three different banks
sequentially
.to(Constants.BANK1_URI, Constants.BANK2_URI,
Constants.BANK3_URI);
- // Router 2 to call the bank endpoints parallelly
+ // Router 2 to call the bank endpoints in parallel
from(Constants.PARALLEL_LOANBROKER_URI)
.process(new CreditScoreProcessor(Constants.CREDITAGENCY_ADDRESS))
- // Using the thread pool to send out message to the below
three different banks parallelly
+ // Using the thread pool to send out messages to three
different banks in parallel
.multicast(new BankResponseAggregationStrategy())
// Camel will create a thread pool with the size of the
send to endpoints
- // for sending the message parallelly
+ // for sending the message in parallel
.setParallelProcessing(true)
.to(Constants.BANK1_URI, Constants.BANK2_URI,
Constants.BANK3_URI);
