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

リスト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>