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 2009/08/06 11:14:08 UTC
svn commit: r801553 - in /camel/sandbox/tuning-experiment/camel-core/src:
main/java/org/apache/camel/processor/Pipeline.java
test/java/org/apache/camel/processor/AOPAroundFinallyTest.java
Author: davsclaus
Date: Thu Aug 6 09:14:07 2009
New Revision: 801553
URL: http://svn.apache.org/viewvc?rev=801553&view=rev
Log:
Fixed unit test.
Modified:
camel/sandbox/tuning-experiment/camel-core/src/main/java/org/apache/camel/processor/Pipeline.java
camel/sandbox/tuning-experiment/camel-core/src/test/java/org/apache/camel/processor/AOPAroundFinallyTest.java
Modified: camel/sandbox/tuning-experiment/camel-core/src/main/java/org/apache/camel/processor/Pipeline.java
URL: http://svn.apache.org/viewvc/camel/sandbox/tuning-experiment/camel-core/src/main/java/org/apache/camel/processor/Pipeline.java?rev=801553&r1=801552&r2=801553&view=diff
==============================================================================
--- camel/sandbox/tuning-experiment/camel-core/src/main/java/org/apache/camel/processor/Pipeline.java (original)
+++ camel/sandbox/tuning-experiment/camel-core/src/main/java/org/apache/camel/processor/Pipeline.java Thu Aug 6 09:14:07 2009
@@ -139,7 +139,9 @@
facade = new CopyOnWriteMessageFacade(target);
}
exchange.setIn(facade);
- exchange.setOut(null);
+ if (exchange.hasOut()) {
+ exchange.setOut(null);
+ }
return exchange;
}
Modified: camel/sandbox/tuning-experiment/camel-core/src/test/java/org/apache/camel/processor/AOPAroundFinallyTest.java
URL: http://svn.apache.org/viewvc/camel/sandbox/tuning-experiment/camel-core/src/test/java/org/apache/camel/processor/AOPAroundFinallyTest.java?rev=801553&r1=801552&r2=801553&view=diff
==============================================================================
--- camel/sandbox/tuning-experiment/camel-core/src/test/java/org/apache/camel/processor/AOPAroundFinallyTest.java (original)
+++ camel/sandbox/tuning-experiment/camel-core/src/test/java/org/apache/camel/processor/AOPAroundFinallyTest.java Thu Aug 6 09:14:07 2009
@@ -28,7 +28,7 @@
public void testAOPAroundFinally() throws Exception {
getMockEndpoint("mock:before").expectedBodiesReceived("Hello World");
- getMockEndpoint("mock:after").message(0).outBody().isEqualTo("Bye World");
+ getMockEndpoint("mock:after").message(0).body().isEqualTo("Bye World");
MockEndpoint mock = getMockEndpoint("mock:result");
mock.expectedBodiesReceived("Bye World");
@@ -40,7 +40,7 @@
public void testAOPAroundFinallyWithException() throws Exception {
getMockEndpoint("mock:before").expectedBodiesReceived("Kabom");
- getMockEndpoint("mock:after").message(0).outBody().isEqualTo("Kabom the World");
+ getMockEndpoint("mock:after").message(0).body().isEqualTo("Kabom the World");
try {
template.requestBody("direct:start", "Kabom", String.class);