You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2013/02/07 09:56:25 UTC

svn commit: r1443359 - in /camel/trunk/components/camel-cxf: pom.xml src/test/java/org/apache/camel/component/cxf/converter/PayLoadConvertToPOJOTest.java src/test/resources/org/apache/camel/component/cxf/converter/PayloadConverterBeans.xml

Author: ningjiang
Date: Thu Feb  7 08:56:25 2013
New Revision: 1443359

URL: http://svn.apache.org/viewvc?rev=1443359&view=rev
Log:
Added an unit test for testing JAXB fallback converter with camel-cxf payload dataformat

Added:
    camel/trunk/components/camel-cxf/src/test/java/org/apache/camel/component/cxf/converter/PayLoadConvertToPOJOTest.java
    camel/trunk/components/camel-cxf/src/test/resources/org/apache/camel/component/cxf/converter/PayloadConverterBeans.xml
Modified:
    camel/trunk/components/camel-cxf/pom.xml

Modified: camel/trunk/components/camel-cxf/pom.xml
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-cxf/pom.xml?rev=1443359&r1=1443358&r2=1443359&view=diff
==============================================================================
--- camel/trunk/components/camel-cxf/pom.xml (original)
+++ camel/trunk/components/camel-cxf/pom.xml Thu Feb  7 08:56:25 2013
@@ -142,6 +142,13 @@
       <artifactId>camel-core-xml</artifactId>
       <scope>test</scope>
     </dependency>
+    
+    <!-- Try to test convert PayLoad into POJO -->
+    <dependency>
+       <groupId>org.apache.camel</groupId>
+       <artifactId>camel-jaxb</artifactId>
+       <scope>test</scope>
+    </dependency>
 
     <dependency>
       <groupId>org.apache.camel</groupId>

Added: camel/trunk/components/camel-cxf/src/test/java/org/apache/camel/component/cxf/converter/PayLoadConvertToPOJOTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-cxf/src/test/java/org/apache/camel/component/cxf/converter/PayLoadConvertToPOJOTest.java?rev=1443359&view=auto
==============================================================================
--- camel/trunk/components/camel-cxf/src/test/java/org/apache/camel/component/cxf/converter/PayLoadConvertToPOJOTest.java (added)
+++ camel/trunk/components/camel-cxf/src/test/java/org/apache/camel/component/cxf/converter/PayLoadConvertToPOJOTest.java Thu Feb  7 08:56:25 2013
@@ -0,0 +1,115 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.component.cxf.converter;
+
+import org.apache.camel.CamelContext;
+import org.apache.camel.Exchange;
+import org.apache.camel.Processor;
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.component.cxf.CXFTestSupport;
+import org.apache.camel.non_wrapper.Person;
+import org.apache.camel.non_wrapper.types.GetPerson;
+import org.apache.camel.non_wrapper.types.GetPersonResponse;
+import org.apache.camel.spring.SpringCamelContext;
+import org.apache.camel.test.junit4.CamelTestSupport;
+import org.apache.cxf.jaxws.JaxWsProxyFactoryBean;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.BeforeClass;
+import org.junit.Test;
+import org.springframework.context.support.AbstractXmlApplicationContext;
+import org.springframework.context.support.ClassPathXmlApplicationContext;
+
+public class PayLoadConvertToPOJOTest extends CamelTestSupport {
+    protected AbstractXmlApplicationContext applicationContext;
+    
+    @BeforeClass
+    public static void setUpSystemProperty() {
+        // just force the CXFTestSupport to load before running the test
+        getPort1();
+    }
+    public static int getPort1() {
+        return CXFTestSupport.getPort1();
+    }
+   
+    @Before
+    public void setUp() throws Exception {
+        applicationContext = createApplicationContext();
+        super.setUp();
+        assertNotNull("Should have created a valid spring context", applicationContext);
+    }
+
+    @After
+    public void tearDown() throws Exception {
+        if (applicationContext != null) {
+            applicationContext.destroy();
+        }
+        super.tearDown();
+    }
+    
+    @Override
+    protected CamelContext createCamelContext() throws Exception {
+        return SpringCamelContext.springCamelContext(applicationContext);
+    }
+
+    
+    @Test
+    public void testClient() throws Exception {
+        
+        JaxWsProxyFactoryBean factory = new JaxWsProxyFactoryBean();
+        factory.setAddress("http://localhost:" + getPort1() + "/"
+                        + getClass().getSimpleName() + "/CamelContext/RouterPort");
+        factory.setServiceClass(Person.class);
+        Person person = factory.create(Person.class);
+        GetPerson payload = new GetPerson();
+        payload.setPersonId("1234");
+        
+        GetPersonResponse reply = person.getPerson(payload);
+        assertEquals("Get the wrong person id.", "1234",  reply.getPersonId());
+        
+    }
+    
+
+    
+    @Override
+    protected RouteBuilder createRouteBuilder() {
+        return new RouteBuilder() {
+            public void configure() {
+                from("cxf:bean:routerEndpoint?dataFormat=PAYLOAD").process(new Processor() {
+
+                    @Override
+                    public void process(Exchange exchange) throws Exception {
+                        // just try to turn the payload to the parameter we want
+                        // to use
+                        GetPerson request = exchange.getIn().getBody(GetPerson.class);
+
+                        GetPersonResponse reply = new GetPersonResponse();
+                        reply.setPersonId(request.getPersonId());
+                        exchange.getOut().setBody(reply);
+                    }
+
+                });
+            }
+        };
+    }
+    
+    protected ClassPathXmlApplicationContext createApplicationContext() {
+        return new ClassPathXmlApplicationContext("org/apache/camel/component/cxf/converter/PayloadConverterBeans.xml");
+    }
+
+
+}

Added: camel/trunk/components/camel-cxf/src/test/resources/org/apache/camel/component/cxf/converter/PayloadConverterBeans.xml
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-cxf/src/test/resources/org/apache/camel/component/cxf/converter/PayloadConverterBeans.xml?rev=1443359&view=auto
==============================================================================
--- camel/trunk/components/camel-cxf/src/test/resources/org/apache/camel/component/cxf/converter/PayloadConverterBeans.xml (added)
+++ camel/trunk/components/camel-cxf/src/test/resources/org/apache/camel/component/cxf/converter/PayloadConverterBeans.xml Thu Feb  7 08:56:25 2013
@@ -0,0 +1,34 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+    Licensed to the Apache Software Foundation (ASF) under one or more
+    contributor license agreements.  See the NOTICE file distributed with
+    this work for additional information regarding copyright ownership.
+    The ASF licenses this file to You under the Apache License, Version 2.0
+    (the "License"); you may not use this file except in compliance with
+    the License.  You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+    Unless required by applicable law or agreed to in writing, software
+    distributed under the License is distributed on an "AS IS" BASIS,
+    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+    See the License for the specific language governing permissions and
+    limitations under the License.
+-->
+<beans xmlns="http://www.springframework.org/schema/beans"
+       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+       xmlns:cxf="http://camel.apache.org/schema/cxf"
+
+       xsi:schemaLocation="
+       http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
+       http://camel.apache.org/schema/cxf http://camel.apache.org/schema/cxf/camel-cxf.xsd
+       http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd
+    ">
+   
+   <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
+   
+   <cxf:cxfEndpoint id="routerEndpoint" address="http://localhost:${CXFTestSupport.port1}/PayLoadConvertToPOJOTest/CamelContext/RouterPort"
+    		serviceClass="org.apache.camel.non_wrapper.Person"/>
+  
+
+</beans>
\ No newline at end of file