Author: hadrian
Date: Thu Apr 12 00:09:57 2012
New Revision: 1325076
URL: http://svn.apache.org/viewvc?rev=1325076&view=rev
Log:
Merged revisions 1311730 via svnmerge from
https://svn.apache.org/repos/asf/camel/trunk
........
r1311730 | ningjiang | 2012-04-10 10:04:40 -0400 (Tue, 10 Apr 2012) | 1 line
Polish the comments of the CamelDestinationTest
........
Modified:
camel/branches/camel-2.9.x/ (props changed)
camel/branches/camel-2.9.x/components/camel-cxf-transport/src/test/java/org/apache/camel/component/cxf/transport/CamelDestinationTest.java
Propchange: camel/branches/camel-2.9.x/
------------------------------------------------------------------------------
Binary property 'svnmerge-integrated' - no diff available.
Modified:
camel/branches/camel-2.9.x/components/camel-cxf-transport/src/test/java/org/apache/camel/component/cxf/transport/CamelDestinationTest.java
URL:
http://svn.apache.org/viewvc/camel/branches/camel-2.9.x/components/camel-cxf-transport/src/test/java/org/apache/camel/component/cxf/transport/CamelDestinationTest.java?rev=1325076&r1=1325075&r2=1325076&view=diff
==============================================================================
---
camel/branches/camel-2.9.x/components/camel-cxf-transport/src/test/java/org/apache/camel/component/cxf/transport/CamelDestinationTest.java
(original)
+++
camel/branches/camel-2.9.x/components/camel-cxf-transport/src/test/java/org/apache/camel/component/cxf/transport/CamelDestinationTest.java
Thu Apr 12 00:09:57 2012
@@ -162,7 +162,7 @@ public class CamelDestinationTest extend
endpointInfo.setAddress("camel://direct:EndpointA");
final CamelDestination destination =
setupCamelDestination(endpointInfo, true);
- // set up MessageObserver for handlering the conduit message
+ // set up MessageObserver for handling the conduit message
MessageObserver observer = new MessageObserver() {
public void onMessage(Message m) {
try {
@@ -186,11 +186,11 @@ public class CamelDestinationTest extend
error.expectedMessageCount(0);
//this call will active the camelDestination
destination.setMessageObserver(observer);
- // set is oneway false for get response from destination
+ // set is one way false for get response from destination
// need to use another thread to send the request message
sendoutMessage(conduit, outMessage, false, "HelloWorld");
// wait for the message to be got from the destination,
- // create the thread to handler the Destination incomming message
+ // create the thread to handler the Destination incoming message
verifyReceivedMessage(inMessage, "HelloWorld Response");
error.assertIsSatisfied();
@@ -211,7 +211,7 @@ public class CamelDestinationTest extend
final CamelDestination destination =
setupCamelDestination(endpointInfo, true);
destination.setCheckException(true);
- // set up MessageObserver for handlering the conduit message
+ // set up MessageObserver for handling the conduit message
MessageObserver observer = new MessageObserver() {
public void onMessage(Message m) {
try {
@@ -238,11 +238,11 @@ public class CamelDestinationTest extend
//this call will active the camelDestination
destination.setMessageObserver(observer);
- // set is oneway false for get response from destination
+ // set is one way false for get response from destination
// need to use another thread to send the request message
sendoutMessage(conduit, outMessage, false, "HelloWorld");
// wait for the message to be got from the destination,
- // create the thread to handler the Destination incomming message
+ // create the thread to handler the Destination incoming message
verifyReceivedMessage(inMessage, "HelloWorld Fault");
error.assertIsSatisfied();
@@ -261,7 +261,7 @@ public class CamelDestinationTest extend
EasyMock.replay(dest);
ConsumerProcessor consumerProcessor = dest.new ConsumerProcessor();
- // Send our dummy exchange and check that the exception that occured
on incoming is set
+ // Send our dummy exchange and check that the exception that occurred
on incoming is set
DefaultExchange exchange = new DefaultExchange(camelContext);
consumerProcessor.process(exchange);
Exception exc = exchange.getException();