Author: ningjiang
Date: Thu Jun 14 02:39:13 2012
New Revision: 1350077
URL: http://svn.apache.org/viewvc?rev=1350077&view=rev
Log:
Fix the CS errors of camel-core
Modified:
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/OnCompletionContainsTest.java
Modified:
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/OnCompletionContainsTest.java
URL:
http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/OnCompletionContainsTest.java?rev=1350077&r1=1350076&r2=1350077&view=diff
==============================================================================
---
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/OnCompletionContainsTest.java
(original)
+++
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/OnCompletionContainsTest.java
Thu Jun 14 02:39:13 2012
@@ -27,26 +27,26 @@ import org.apache.camel.support.Synchron
*/
public class OnCompletionContainsTest extends ContextTestSupport {
- class SimpleSynchronizationAdapter extends SynchronizationAdapter {
- private String endPoint;
- private String body;
-
- SimpleSynchronizationAdapter(String endPoint, String body) {
- super();
- this.endPoint = endPoint;
- this.body = body;
- }
-
- @Override
- public void onDone(Exchange exchange) {
- template.sendBody(endPoint, body);
- }
-
- @Override
- public String toString() {
- return body;
- }
- }
+ class SimpleSynchronizationAdapter extends SynchronizationAdapter {
+ private String endPoint;
+ private String body;
+
+ SimpleSynchronizationAdapter(String endPoint, String body) {
+ super();
+ this.endPoint = endPoint;
+ this.body = body;
+ }
+
+ @Override
+ public void onDone(Exchange exchange) {
+ template.sendBody(endPoint, body);
+ }
+
+ @Override
+ public String toString() {
+ return body;
+ }
+ }
public void testOnCompletionContainsTest() throws Exception {
getMockEndpoint("mock:sync").expectedBodiesReceived("C", "B", "B",
"A", "Hello World");
@@ -64,40 +64,41 @@ public class OnCompletionContainsTest ex
public void configure() throws Exception {
onCompletion().to("mock:sync");
- from("direct:start")
- .process(new Processor() {
- public void process(Exchange exchange) throws
Exception {
- SynchronizationAdapter
adapter = new SimpleSynchronizationAdapter("mock:sync", "A");
+ from("direct:start").process(new Processor() {
+ public void process(Exchange exchange) throws Exception {
+ SynchronizationAdapter adapter = new
SimpleSynchronizationAdapter("mock:sync", "A");
+ exchange.addOnCompletion(adapter);
+
+ // should not add the adapter again as we already have
+ // it
+ if (!exchange.containsOnCompletion(adapter)) {
exchange.addOnCompletion(adapter);
+ }
- // should not add the
adapter again as we already have it
- if
(!exchange.containsOnCompletion(adapter)) {
-
exchange.addOnCompletion(adapter);
- }
+ adapter = new
SimpleSynchronizationAdapter("mock:sync", "B");
+ exchange.addOnCompletion(adapter);
- adapter = new
SimpleSynchronizationAdapter("mock:sync", "B");
+ // now add the B again as we want to test that this
also
+ // work
+ if (exchange.containsOnCompletion(adapter)) {
exchange.addOnCompletion(adapter);
-
- // now add the B again
as we want to test that this also work
- if
(exchange.containsOnCompletion(adapter)) {
-
exchange.addOnCompletion(adapter);
- }
-
- // add a C that is no a
SimpleSynchronizationAdapter class
- exchange.addOnCompletion(new
SynchronizationAdapter() {
- @Override
- public void onDone(Exchange exchange) {
- template.sendBody("mock:sync", "C");
- }
-
- @Override
- public String toString() {
- return "C";
- }
- });
}
- })
- .to("mock:result");
+
+ // add a C that is no a SimpleSynchronizationAdapter
+ // class
+ exchange.addOnCompletion(new SynchronizationAdapter() {
+ @Override
+ public void onDone(Exchange exchange) {
+ template.sendBody("mock:sync", "C");
+ }
+
+ @Override
+ public String toString() {
+ return "C";
+ }
+ });
+ }
+ }).to("mock:result");
}
};
}
