JBoss Fuseを使ってみる その3：Webサービス編

リスト1：pom.xmlに追加する依存ライブラリの設定

<dependency>
    <groupId>org.apache.camel</groupId>
    <artifactId>camel-cxf</artifactId>
    <version>2.12.0.redhat-610379</version>
</dependency>
<dependency>
    <groupId>org.apache.cxf</groupId>
    <artifactId>cxf-rt-transports-http</artifactId>
    <version>2.7.0.redhat-610379</version>
</dependency>

リスト2

package com.mycompany.wsserver;
import javax.jws.WebService;
@WebService
public interface OrderEndpoint {
    String order(String OrderID);
}

リスト3

<?xml version="1.0" encoding="UTF-8"?>
<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
       xmlns:camel="http://camel.apache.org/schema/blueprint"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:cxf="http://camel.apache.org/schema/blueprint/cxf"
       xsi:schemaLocation="http://www.osgi.org/xmlns/blueprint/v1.0.0 http://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd
       http://camel.apache.org/schema/blueprint/cxf http://camel.apache.org/schema/blueprint/cxf/camel-cxf.xsd
       http://camel.apache.org/schema/blueprint http://camel.apache.org/schema/blueprint/camel-blueprint.xsd">
  <cxf:cxfEndpoint id="orderEndpoint"
       address="/order/"
       serviceClass="com.mycompany.wsserver.OrderEndpoint"/>
  <camelContext trace="false" xmlns="http://camel.apache.org/schema/blueprint">
    <route>
        <from uri="cxf:bean:orderEndpoint"/>
        <transform>
            <constant>OK : ${body}</constant>
        </transform>
    </route>
</camelContext>
</blueprint>

リスト4

  <cxf:cxfEndpoint id="orderEndpoint" (1)
       address="/order/"
       serviceClass="com.mycompany.wsserver.OrderEndpoint"/> (2)
  <camelContext trace="false" xmlns="http://camel.apache.org/schema/blueprint">
    <route>
        <from uri="cxf:bean:orderEndpoint"/>

リスト5：Customer.java

package com.mycompany.wsserver.rest;

import javax.xml.bind.annotation.XmlAttribute;
import javax.xml.bind.annotation.XmlElement;

public class Customer {
        private String id;
        private String firstName;
        private String lastName;
        private int age;
        public Customer(){}
        public Customer(String id, String firstName, String lastName, int age) {
                this.id = id;
                this.firstName = firstName;
                this.lastName = lastName;
                this.age = age;
        }
        public String getId() {
                return id;
        }
        @XmlAttribute
        public void setId(String id) {
                this.id = id;
        }
        public String getFirstName() {
                return firstName;
        }
        @XmlElement
        public void setFirstName(String firstName) {
                this.firstName = firstName;
        }
        public String getLastName() {
                return lastName;
        }
        @XmlElement
        public void setLastName(String lastName) {
                this.lastName = lastName;
        }
        public int getAge() {
                return age;
        }
        @XmlElement
        public void setAge(int age) {
                this.age = age;
        }
        @Override
        public String toString() {
                StringBuilder builder = new StringBuilder();
                builder.append("Customer [id=").append(id).append(", firstName=")
                                .append(firstName).append(", lastName=").append(lastName)
                                .append(", age=").append(age).append("]");
                return builder.toString();
        }
}

リスト6：CustomerList.java

package com.mycompany.wsserver.rest;

import java.util.ArrayList;
import java.util.List;
import javax.xml.bind.annotation.XmlElement;
import javax.xml.bind.annotation.XmlRootElement;

@XmlRootElement(name="CustomerList")
public class CustomerList {
        private List<Customer> customers;
        public CustomerList(){
                setCustomers(new ArrayList<Customer>());
        }
        public List<Customer> getCustomers() {
                return customers;
        }
        @XmlElement(name="customer")
        public void setCustomers(List<Customer> customers) {
                this.customers = customers;
        }
        public void addCustomer(Customer customer){
                customers.add(customer);
        }
}

リスト7：インターフェースの作成（CustomerEndpoint.java）

package com.mycompany.wsserver.rest;

import javax.ws.rs.GET;
import javax.ws.rs.Path;
import javax.ws.rs.PathParam;
import javax.ws.rs.Produces;

public interface CustomerEndpoint {
        @GET
        @Path("/list")
        @Produces("application/xml")
        public CustomerList listCustomer();

        @GET
        @Path("/add/{id}/{firstname}/{lastname}/{age}")
        @Produces("application/xml")
        public CustomerList addCustomer(@PathParam("id") String id, @PathParam("firstname") String firstname, @PathParam("lastname") String lastname, @PathParam("age") int age);
}

リスト8：listCustomerメソッドに対する処理（ListCustomerProcessor.java）

package com.mycompany.wsserver.rest;

import javax.ws.rs.core.Response;
import org.apache.camel.Processor;
import org.apache.camel.Exchange;

public class ListCustomerProcessor implements Processor {

    @Override
    public void process(Exchange exchange) throws Exception {   CustomerList list = new CustomerList ();
        list.addCustomer(new Customer("0001", "一郎", "佐藤", 20));
        list.addCustomer(new Customer("0002", "花子", "鈴木", 24));
        Response r = Response.status(200).entity(list).build();
        exchange.getOut().setBody(r);
    }
}

リスト9：addCustomerメソッドに対する処理（AddCustomerProcessor.java）

package com.mycompany.wsserver.rest;

import java.util.List;
import javax.ws.rs.core.Response;
import org.apache.camel.Exchange;
import org.apache.camel.Message;
import org.apache.camel.Processor;

public class AddCustomerProcessor implements Processor {

        @Override
        public void process(Exchange exchange) throws Exception {
                Message message = exchange.getIn();
                @SuppressWarnings("unchecked")
                List<Object> listBody = (List<Object>) message.getBody();

                CustomerList list = new CustomerList();
                String id = (String) listBody.get(0);
                String firstname = (String) listBody.get(1);
                String lastname = (String) listBody.get(2);
                int age = (Integer) listBody.get(3);
                list.addCustomer(new Customer(id,firstname,lastname,age));
                Response r = Response.status(200).entity(list).build();
                exchange.getOut().setBody(r);
        }

}

リスト10：RESTサーバー（Sourceモード）

<?xml version="1.0" encoding="UTF-8"?>
<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
       xmlns:camel="http://camel.apache.org/schema/blueprint"
       xmlns:cxf="http://camel.apache.org/schema/blueprint/cxf"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="http://www.osgi.org/xmlns/blueprint/v1.0.0 http://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd
       http://camel.apache.org/schema/blueprint/cxf http://camel.apache.org/schema/blueprint/cxf/camel-cxf.xsd
       http://camel.apache.org/schema/blueprint http://camel.apache.org/schema/blueprint/camel-blueprint.xsd">

  <cxf:rsServer id="restServer" address="/customer"/>
  <bean id="listCustomerProcessor" class="com.mycompany.wsserver.rest.ListCustomerProcessor"/>
  <bean id="addCustomerProcessor" class="com.mycompany.wsserver.rest.AddCustomerProcessor"/>
  <camelContext trace="false" xmlns="http://camel.apache.org/schema/blueprint">
    <route>
        <from uri="cxfrs:bean:restServer?resourceClasses=com.mycompany.wsserver.rest.CustomerEndpoint"/>
        <choice>
            <when>
                <simple>${in.header.operationName} == 'listCustomer'</simple>
                <process ref="listCustomerProcessor"/>
                <log message="${body}"/>
            </when>
            <when>
                <simple>${in.header.operationName} == 'addCustomer'</simple>
                <process ref="addCustomerProcessor"/>
                <log message="${body}"/>
            </when>
        </choice>
    </route>
</camelContext>
</blueprint>

リスト11：pom.xmlに記述する依存ライブラリ

<dependency>
    <groupId>org.apache.camel</groupId>
    <artifactId>camel-cxf</artifactId>
    <version>2.12.0.redhat-610379</version>
</dependency>
<dependency>
    <groupId>org.apache.cxf</groupId>
    <artifactId>cxf-rt-transports-http</artifactId>
    <version>2.7.0.redhat-610379</version>
</dependency>
<dependency>
    <groupId>org.apache.cxf</groupId>
    <artifactId>cxf-rt-frontend-jaxws</artifactId>
    <version>2.7.0.redhat-610379</version>
</dependency>
<dependency>
    <groupId>org.apache.cxf</groupId>
    <artifactId>cxf-rt-frontend-jaxrs</artifactId>
    <version>2.7.0.redhat-610379</version>
</dependency>

リスト12：pom.xmlに追加する内容

<plugin>
    <groupId>org.apache.cxf</groupId>
        <artifactId>cxf-codegen-plugin</artifactId>
        <version>2.7.0.redhat-610379</version>
        <executions>
                  <execution>
                <phase>generate-sources</phase>
              <goals>
                <goal>wsdl2java</goal>
              </goals>
              <configuration>
                  <sourceRoot>
                      ${project.basedir}/generated
                  </sourceRoot>
                  <wsdlOptions>
                    <wsdlOption>
                        <wsdl>${project.basedir}/src/main/resources/wsdl/OrderEndpointService.wsdl</wsdl>
                        <extraargs>
                              <extraarg>-fe</extraarg>
                          <extraarg>jaxws21</extraarg>
                        </extraargs>
                    </wsdlOption>
                  </wsdlOptions>
              </configuration>
        </execution>
    </executions>
</plugin>

リスト13：SOAPクライアントのCamelクライアント（Sourceモード）

<?xml version="1.0" encoding="UTF-8"?>
<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:camel="http://camel.apache.org/schema/blueprint"
       xmlns:cxf="http://camel.apache.org/schema/blueprint/cxf"
       xsi:schemaLocation="
       http://www.osgi.org/xmlns/blueprint/v1.0.0 http://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd
       http://camel.apache.org/schema/blueprint/cxf http://camel.apache.org/schema/blueprint/cxf/camel-cxf.xsd
       http://camel.apache.org/schema/blueprint http://camel.apache.org/schema/blueprint/camel-blueprint.xsd">
  <cxf:cxfEndpoint id="soapClient"
        address="http://localhost:8181/cxf/order/"
        serviceClass="com.mycompany.wsserver.OrderEndpoint"/>
  <camelContext trace="false" id="blueprintContext" xmlns="http://camel.apache.org/schema/blueprint">
    <route>
        <from uri="timer:foo?period=30000"/>
        <transform>
            <simple>sample</simple>
        </transform>
        <to uri="cxf:bean:soapClient"/>
        <log message="メッセージ : ${body} "/>
    </route>
</camelContext>
</blueprint>

リスト14：RESTクライアントのCamelルート（Sourceモード）

<?xml version="1.0" encoding="UTF-8"?>
<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
       xmlns:camel="http://camel.apache.org/schema/blueprint"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:cxf="http://camel.apache.org/schema/blueprint/cxf"
       xsi:schemaLocation="http://www.osgi.org/xmlns/blueprint/v1.0.0 http://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd
       http://camel.apache.org/schema/blueprint/cxf http://camel.apache.org/schema/blueprint/cxf/camel-cxf.xsd
       http://camel.apache.org/schema/blueprint http://camel.apache.org/schema/blueprint/camel-blueprint.xsd">
  <cxf:rsClient id="restClient"
        address="http://localhost:8181"/>
  <camelContext trace="false" xmlns="http://camel.apache.org/schema/blueprint">
    <route>
        <from uri="timer:bar?period=40000"/>
        <setHeader headerName="Exchange.HTTP_PATH">
            <simple>/cxf/customer/add/0010/テスト/サンプル/20</simple>
        </setHeader>
        <setHeader headerName="Exchange.HTTP_METHOD">
            <simple>GET</simple>
        </setHeader>
        <setExchangePattern pattern="InOut"/>
        <to uri="cxfrs:bean:restClient"/>
        <log message="REST : レスポンスメッセージ : ${body}"/>
    </route>
</camelContext>
</blueprint>