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 2011/12/26 13:31:43 UTC
svn commit: r1224727 - in
/camel/trunk/examples/camel-example-loan-broker/src:
main/java/org/apache/camel/loanbroker/queue/version/
main/java/org/apache/camel/loanbroker/webservice/version/
main/java/org/apache/camel/loanbroker/webservice/version/bank/...
Author: davsclaus
Date: Mon Dec 26 12:31:42 2011
New Revision: 1224727
URL: http://svn.apache.org/viewvc?rev=1224727&view=rev
Log:
Polished
Modified:
camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/queue/version/BankResponseAggregationStrategy.java
camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/queue/version/Client.java
camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/queue/version/JmsBroker.java
camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/queue/version/LoanBroker.java
camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/queue/version/Translator.java
camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/Client.java
camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/LoanBroker.java
camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/LoanBrokerWS.java
camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/bank/Bank.java
camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/bank/BankQuote.java
camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/bank/BankServer.java
camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/bank/BankWS.java
camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/credit/CreditAgency.java
camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/credit/CreditAgencyServer.java
camel/trunk/examples/camel-example-loan-broker/src/test/java/org/apache/camel/loanbroker/queue/version/LoanBrokerQueueTest.java
Modified: camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/queue/version/BankResponseAggregationStrategy.java
URL: http://svn.apache.org/viewvc/camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/queue/version/BankResponseAggregationStrategy.java?rev=1224727&r1=1224726&r2=1224727&view=diff
==============================================================================
--- camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/queue/version/BankResponseAggregationStrategy.java (original)
+++ camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/queue/version/BankResponseAggregationStrategy.java Mon Dec 26 12:31:42 2011
@@ -28,7 +28,7 @@ public class BankResponseAggregationStra
// Here we put the bank response together
public Exchange aggregate(Exchange oldExchange, Exchange newExchange) {
- LOG.debug("Get the exchange to aggregate, older: " + oldExchange + " newer:" + newExchange);
+ LOG.debug("oldExchange: {}, newExchange: {}", oldExchange, newExchange);
// the first time we only have the new exchange
if (oldExchange == null) {
@@ -51,7 +51,7 @@ public class BankResponseAggregationStra
result = newExchange;
}
- LOG.debug("Get the lower rate exchange " + result);
+ LOG.debug("Lowest rate exchange: {}", result);
return result;
}
Modified: camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/queue/version/Client.java
URL: http://svn.apache.org/viewvc/camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/queue/version/Client.java?rev=1224727&r1=1224726&r2=1224727&view=diff
==============================================================================
--- camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/queue/version/Client.java (original)
+++ camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/queue/version/Client.java Mon Dec 26 12:31:42 2011
@@ -27,6 +27,7 @@ import org.apache.camel.ProducerTemplate
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.jms.JmsComponent;
import org.apache.camel.impl.DefaultCamelContext;
+
//START SNIPPET: client
public class Client extends RouteBuilder {
@@ -46,7 +47,7 @@ public class Client extends RouteBuilder
// send out the request message
for (int i = 0; i < 2; i++) {
template.sendBodyAndHeader("jms:queue:loanRequestQueue",
- "Quote for the lowerst rate of loaning bank",
+ "Quote for the lowest rate of loaning bank",
Constants.PROPERTY_SSN, "Client-A" + i);
Thread.sleep(100);
}
@@ -57,7 +58,7 @@ public class Client extends RouteBuilder
Exchange exchange = template.send("jms:queue2:parallelLoanRequestQueue", new Processor() {
public void process(Exchange exchange) throws Exception {
exchange.setPattern(ExchangePattern.InOut);
- exchange.getIn().setBody("Quote for the lowerst rate of loaning bank");
+ exchange.getIn().setBody("Quote for the lowst rate of loaning bank");
exchange.getIn().setHeader(Constants.PROPERTY_SSN, "Client-B");
}
});
@@ -65,30 +66,24 @@ public class Client extends RouteBuilder
String bank = (String)exchange.getOut().getHeader(Constants.PROPERTY_BANK);
Double rate = (Double)exchange.getOut().getHeader(Constants.PROPERTY_RATE);
String ssn = (String)exchange.getOut().getHeader(Constants.PROPERTY_SSN);
- System.out.println("Loan quotion for Client " + ssn + "."
- + " The lowest rate bank is " + bank + ", the rate is " + rate);
+ System.out.println("Loan quote for Client " + ssn + "."
+ + " The lowest rate bank is " + bank + ", with rate " + rate);
// Wait a while before stop the context
Thread.sleep(1000 * 5);
context.stop();
-
}
/**
* Lets configure the Camel routing rules using Java code to pull the response message
*/
public void configure() {
-
from("jms:queue:loanReplyQueue").process(new Processor() {
-
public void process(Exchange exchange) throws Exception {
// Print out the response message
System.out.println(exchange.getIn().getBody());
-
}
-
});
-
}
}
Modified: camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/queue/version/JmsBroker.java
URL: http://svn.apache.org/viewvc/camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/queue/version/JmsBroker.java?rev=1224727&r1=1224726&r2=1224727&view=diff
==============================================================================
--- camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/queue/version/JmsBroker.java (original)
+++ camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/queue/version/JmsBroker.java Mon Dec 26 12:31:42 2011
@@ -14,7 +14,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.camel.loanbroker.queue.version;
import java.io.File;
@@ -25,7 +24,7 @@ import org.apache.activemq.store.memory.
public final class JmsBroker {
JMSEmbeddedBroker jmsBrokerThread;
String jmsBrokerUrl = "tcp://localhost:51616";
- String activeMQStorageDir;
+
public JmsBroker() {
}
@@ -42,10 +41,7 @@ public final class JmsBroker {
synchronized (this) {
jmsBrokerThread.shutdownBroker = true;
}
- if (jmsBrokerThread != null) {
- jmsBrokerThread.join();
- }
-
+ jmsBrokerThread.join();
jmsBrokerThread = null;
}
@@ -53,8 +49,7 @@ public final class JmsBroker {
boolean shutdownBroker;
final String brokerUrl;
Exception exception;
-
-
+
public JMSEmbeddedBroker(String url) {
brokerUrl = url;
}
@@ -75,7 +70,6 @@ public final class JmsBroker {
public void run() {
try {
- //ContainerWapper container;
BrokerService broker = new BrokerService();
synchronized (this) {
broker.setPersistenceAdapter(new MemoryPersistenceAdapter());
@@ -91,7 +85,6 @@ public final class JmsBroker {
}
}
broker.stop();
- broker = null;
} catch (Exception e) {
exception = e;
e.printStackTrace();
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=1224727&r1=1224726&r2=1224727&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 Mon Dec 26 12:31:42 2011
@@ -81,13 +81,11 @@ public class LoanBroker extends RouteBui
// 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())
.completionPredicate(header(Exchange.AGGREGATED_SIZE).isEqualTo(3))
- // Here we do some translation and put the message back to loanReplyQueue
+ // Here we do some translation and put the message back to loanReplyQueue
.process(new Translator()).to("jms:queue:loanReplyQueue");
// END SNIPPET: dsl
Modified: camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/queue/version/Translator.java
URL: http://svn.apache.org/viewvc/camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/queue/version/Translator.java?rev=1224727&r1=1224726&r2=1224727&view=diff
==============================================================================
--- camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/queue/version/Translator.java (original)
+++ camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/queue/version/Translator.java Mon Dec 26 12:31:42 2011
@@ -26,8 +26,8 @@ public class Translator implements Proce
String bank = (String)exchange.getIn().getHeader(Constants.PROPERTY_BANK);
Double rate = (Double)exchange.getIn().getHeader(Constants.PROPERTY_RATE);
String ssn = (String)exchange.getIn().getHeader(Constants.PROPERTY_SSN);
- exchange.getOut().setBody("Loan quotion for Client " + ssn + "."
- + " The lowest rate bank is " + bank + ", the rate is " + rate);
+ exchange.getOut().setBody("Loan quote for Client " + ssn + "."
+ + " The lowest rate bank is " + bank + ", with rate " + rate);
}
}
Modified: camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/Client.java
URL: http://svn.apache.org/viewvc/camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/Client.java?rev=1224727&r1=1224726&r2=1224727&view=diff
==============================================================================
--- camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/Client.java (original)
+++ camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/Client.java Mon Dec 26 12:31:42 2011
@@ -14,10 +14,8 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.camel.loanbroker.webservice.version;
-
import org.apache.cxf.BusFactory;
import org.apache.cxf.frontend.ClientFactoryBean;
import org.apache.cxf.frontend.ClientProxyFactoryBean;
@@ -25,7 +23,6 @@ import org.apache.cxf.frontend.ClientPro
/**
* The client that will invoke the loan broker service
*/
-
//START SNIPPET: client
public class Client {
@@ -41,18 +38,21 @@ public class Client {
public static void main(String[] args) {
Client client = new Client();
- String result = null;
LoanBrokerWS loanBroker = client.getProxy(Constants.LOANBROKER_ADDRESS);
+
long startTime = System.currentTimeMillis();
- result = loanBroker.getLoanQuote("Sequential SSN", 1000.54, 10);
+ String result = loanBroker.getLoanQuote("Sequential SSN", 1000.54, 10);
long endTime = System.currentTimeMillis();
+
System.out.println("It takes " + (endTime - startTime) + " milliseconds to call the sequential loan broker service");
System.out.println(result);
- LoanBrokerWS paralleLoanBroker = client.getProxy(Constants.PARALLEL_LOANBROKER_ADDRESS);
+ LoanBrokerWS parallelLoanBroker = client.getProxy(Constants.PARALLEL_LOANBROKER_ADDRESS);
+
startTime = System.currentTimeMillis();
- result = paralleLoanBroker.getLoanQuote("Parallel SSN", 1000.54, 10);
+ result = parallelLoanBroker.getLoanQuote("Parallel SSN", 1000.54, 10);
endTime = System.currentTimeMillis();
+
System.out.println("It takes " + (endTime - startTime) + " milliseconds to call the parallel loan broker service");
System.out.println(result);
}
Modified: camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/LoanBroker.java
URL: http://svn.apache.org/viewvc/camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/LoanBroker.java?rev=1224727&r1=1224726&r2=1224727&view=diff
==============================================================================
--- camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/LoanBroker.java (original)
+++ camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/LoanBroker.java Mon Dec 26 12:31:42 2011
@@ -16,7 +16,6 @@
*/
package org.apache.camel.loanbroker.webservice.version;
-
import java.util.ArrayList;
import java.util.List;
@@ -34,12 +33,8 @@ import org.apache.cxf.BusFactory;
import org.apache.cxf.frontend.ClientFactoryBean;
import org.apache.cxf.jaxws.JaxWsProxyFactoryBean;
-
-
/**
* The LoanBroker is a RouteBuilder which builds the whole loan message routing rules
- *
- *
*/
public class LoanBroker extends RouteBuilder {
@@ -66,6 +61,7 @@ public class LoanBroker extends RouteBui
creditAgencyServer.stop();
}
//END SNIPPET: server
+
/**
* Lets configure the Camel routing rules using Java code...
*/
@@ -121,7 +117,7 @@ public class LoanBroker extends RouteBui
String ssn = (String)request.get(0);
Double amount = (Double) request.get(1);
- Integer loanDuriation = (Integer)request.get(2);
+ Integer loanDuration = (Integer)request.get(2);
int historyLength = proxy.getCreditHistoryLength(ssn);
int score = proxy.getCreditScore(ssn);
@@ -129,7 +125,7 @@ public class LoanBroker extends RouteBui
List<Object> bankRequest = new ArrayList<Object>();
bankRequest.add(ssn);
bankRequest.add(amount);
- bankRequest.add(loanDuriation);
+ bankRequest.add(loanDuration);
bankRequest.add(historyLength);
bankRequest.add(score);
exchange.getOut().setBody(bankRequest);
Modified: camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/LoanBrokerWS.java
URL: http://svn.apache.org/viewvc/camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/LoanBrokerWS.java?rev=1224727&r1=1224726&r2=1224727&view=diff
==============================================================================
--- camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/LoanBrokerWS.java (original)
+++ camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/LoanBrokerWS.java Mon Dec 26 12:31:42 2011
@@ -21,7 +21,7 @@ package org.apache.camel.loanbroker.webs
// This SEI has no @WebService annotation, we use the simple frontend API to create client and server
public interface LoanBrokerWS {
- String getLoanQuote(String ssn, Double loanAmount, Integer loanDuriation);
+ String getLoanQuote(String ssn, Double loanAmount, Integer loanDuration);
}
//END SNIPPET: loanBroker
Modified: camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/bank/Bank.java
URL: http://svn.apache.org/viewvc/camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/bank/Bank.java?rev=1224727&r1=1224726&r2=1224727&view=diff
==============================================================================
--- camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/bank/Bank.java (original)
+++ camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/bank/Bank.java Mon Dec 26 12:31:42 2011
@@ -15,6 +15,7 @@
* limitations under the License.
*/
package org.apache.camel.loanbroker.webservice.version.bank;
+
//START SNIPPET: bankImpl
public class Bank implements BankWS {
private String bankName;
@@ -30,7 +31,7 @@ public class Bank implements BankWS {
}
public BankQuote getQuote(String ssn, double loanAmount, int loanDuration, int creditHistory, int creditScore) {
- Double rate = primeRate + (double)(loanDuration / 12) / 10 + (double)(Math.random() * 10) / 10;
+ Double rate = primeRate + (double)(loanDuration / 12) / 10 + Math.random() * 10 / 10;
// Wait for a while
try {
Thread.sleep(1000);
Modified: camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/bank/BankQuote.java
URL: http://svn.apache.org/viewvc/camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/bank/BankQuote.java?rev=1224727&r1=1224726&r2=1224727&view=diff
==============================================================================
--- camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/bank/BankQuote.java (original)
+++ camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/bank/BankQuote.java Mon Dec 26 12:31:42 2011
@@ -22,7 +22,6 @@ public class BankQuote {
private Double rate;
public BankQuote() {
-
}
public BankQuote(String name, String s, Double r) {
Modified: camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/bank/BankServer.java
URL: http://svn.apache.org/viewvc/camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/bank/BankServer.java?rev=1224727&r1=1224726&r2=1224727&view=diff
==============================================================================
--- camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/bank/BankServer.java (original)
+++ camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/bank/BankServer.java Mon Dec 26 12:31:42 2011
@@ -14,20 +14,17 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.camel.loanbroker.webservice.version.bank;
import javax.xml.ws.Endpoint;
import org.apache.camel.loanbroker.webservice.version.Constants;
-
-
public class BankServer {
- Endpoint endpoint1;
- Endpoint endpoint2;
- Endpoint endpoint3;
+ private Endpoint endpoint1;
+ private Endpoint endpoint2;
+ private Endpoint endpoint3;
public void start() throws Exception {
System.out.println("Starting Bank Server");
@@ -38,8 +35,6 @@ public class BankServer {
endpoint1 = Endpoint.publish(Constants.BANK1_ADDRESS, bank1);
endpoint2 = Endpoint.publish(Constants.BANK2_ADDRESS, bank2);
endpoint3 = Endpoint.publish(Constants.BANK3_ADDRESS, bank3);
-
-
}
public void stop() {
@@ -54,7 +49,6 @@ public class BankServer {
}
}
-
public static void main(String args[]) throws Exception {
BankServer server = new BankServer();
System.out.println("Server ready...");
Modified: camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/bank/BankWS.java
URL: http://svn.apache.org/viewvc/camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/bank/BankWS.java?rev=1224727&r1=1224726&r2=1224727&view=diff
==============================================================================
--- camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/bank/BankWS.java (original)
+++ camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/bank/BankWS.java Mon Dec 26 12:31:42 2011
@@ -25,7 +25,6 @@ public interface BankWS {
String getBankName();
-
BankQuote getQuote(String ssn, double loanAmount, int loanDuration, int creditHistory, int creditScore);
}
Modified: camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/credit/CreditAgency.java
URL: http://svn.apache.org/viewvc/camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/credit/CreditAgency.java?rev=1224727&r1=1224726&r2=1224727&view=diff
==============================================================================
--- camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/credit/CreditAgency.java (original)
+++ camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/credit/CreditAgency.java Mon Dec 26 12:31:42 2011
@@ -15,6 +15,7 @@
* limitations under the License.
*/
package org.apache.camel.loanbroker.webservice.version.credit;
+
//START SNIPPET: creditAgencyImpl
public class CreditAgency implements CreditAgencyWS {
Modified: camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/credit/CreditAgencyServer.java
URL: http://svn.apache.org/viewvc/camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/credit/CreditAgencyServer.java?rev=1224727&r1=1224726&r2=1224727&view=diff
==============================================================================
--- camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/credit/CreditAgencyServer.java (original)
+++ camel/trunk/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/webservice/version/credit/CreditAgencyServer.java Mon Dec 26 12:31:42 2011
@@ -14,7 +14,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.camel.loanbroker.webservice.version.credit;
import javax.xml.ws.Endpoint;
Modified: camel/trunk/examples/camel-example-loan-broker/src/test/java/org/apache/camel/loanbroker/queue/version/LoanBrokerQueueTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/examples/camel-example-loan-broker/src/test/java/org/apache/camel/loanbroker/queue/version/LoanBrokerQueueTest.java?rev=1224727&r1=1224726&r2=1224727&view=diff
==============================================================================
--- camel/trunk/examples/camel-example-loan-broker/src/test/java/org/apache/camel/loanbroker/queue/version/LoanBrokerQueueTest.java (original)
+++ camel/trunk/examples/camel-example-loan-broker/src/test/java/org/apache/camel/loanbroker/queue/version/LoanBrokerQueueTest.java Mon Dec 26 12:31:42 2011
@@ -97,7 +97,7 @@ public class LoanBrokerQueueTest extends
String ssn = "Client-A" + index;
String result = exchange.getIn().getBody(String.class);
assertNotNull("The result should not be null", result);
- assertTrue("The result is wrong", result.startsWith("Loan quotion for Client " + ssn));
+ assertTrue("The result is wrong", result.startsWith("Loan quote for Client " + ssn));
index++;
}
@@ -105,7 +105,7 @@ public class LoanBrokerQueueTest extends
Exchange exchange = template.send("jms:queue2:parallelLoanRequestQueue", new Processor() {
public void process(Exchange exchange) throws Exception {
exchange.setPattern(ExchangePattern.InOut);
- exchange.getIn().setBody("Quote for the lowerst rate of loaning bank");
+ exchange.getIn().setBody("Quote for the lowest rate of loaning bank");
exchange.getIn().setHeader(Constants.PROPERTY_SSN, "Client-B");
}
});