svn commit: r713026 - in /activemq/camel/trunk/components/camel-cxf: pom.xml src/main/java/org/apache/camel/component/cxf/CxfEndpoint.java

[ningjiang]

Author: ningjiang
Date: Tue Nov 11 04:57:20 2008
New Revision: 713026

URL: http://svn.apache.org/viewvc?rev=713026&view=rev
Log:
Reenable the unit tests in camel-cxf

Modified:
    activemq/camel/trunk/components/camel-cxf/pom.xml
    
activemq/camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfEndpoint.java

Modified: activemq/camel/trunk/components/camel-cxf/pom.xml
URL: 
http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-cxf/pom.xml?rev=713026&r1=713025&r2=713026&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-cxf/pom.xml (original)
+++ activemq/camel/trunk/components/camel-cxf/pom.xml Tue Nov 11 04:57:20 2008
@@ -254,12 +254,7 @@
           <useFile>true</useFile>
           <includes>
             <include>**/*Test.*</include>
-          </includes>
-          <excludes>
-            <exclude>**/CxfGreeterPayLoadRouterTest.*</exclude>
-            <exclude>**/CxfPayLoadMessageRouterTest.*</exclude>
-            <exclude>**/CxfWsdlFirstTest.*</exclude>
-          </excludes>
+          </includes>          
           <systemProperties>
                <property>
                     <name>java.util.logging.config.file</name>

Modified: 
activemq/camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfEndpoint.java
URL: 
http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfEndpoint.java?rev=713026&r1=713025&r2=713026&view=diff
==============================================================================
--- 
activemq/camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfEndpoint.java
 (original)
+++ 
activemq/camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfEndpoint.java
 Tue Nov 11 04:57:20 2008
@@ -88,6 +88,17 @@
     public CxfExchange createExchange(Message inMessage) {
         return new CxfExchange(getCamelContext(), getExchangePattern(), 
inMessage);
     }
+    
+    /* Override the defaultEndpoint exchange create method */
+    public Exchange createExchange(Exchange exchange) {
+        if (exchange instanceof CxfExchange) {
+            return exchange;
+        } else {
+            Exchange answer = createExchange();
+            answer.copyFrom(exchange);
+            return answer;
+        }
+    }
 
     public String getDataFormat() {
         return dataFormat;