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

[davsclaus]

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);