0

我正在尝试创建一个示例 Camel 路由,作为基于简单资源类构建的 RESTful API 的种子,提供 XML 有效负载。

我遇到的问题是我的 GET 正在工作(它所做的只是构建一段 XML)但我的 POST 返回以下错误:-

JAXBException occurred : ParseError at [row,col]:[1,1]
Message: Premature end of file.. ParseError at [row,col]:[1,1]
Message: Premature end of file..

我正在使用通过 xjc 从 XSD 构建的类来定义 XML。我知道这不是 XML 有效负载结构的问题,因为当我将 GET 返回的 XML 复制到 POST 时它甚至会失败!尽管如此,鉴于 JAXB 抱怨第一个字符,我想知道它是否抱怨编码。我使用 cURL 和 Chrome Postman 作为客户端,都收到相同的响应。

我想我只是缺少一个简单的注释或设置,它使 POST 方法 ( newCustomer) 能够解析传入的 XML 有效负载。

这是我的路线 XML:-

<?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:jaxrs="http://cxf.apache.org/blueprint/jaxrs"
    xmlns:cxf="http://cxf.apache.org/blueprint/core"
    xmlns:camel="http://camel.apache.org/schema/blueprint"
    xsi:schemaLocation="
http://www.osgi.org/xmlns/blueprint/v1.0.0 http://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd
http://cxf.apache.org/blueprint/jaxrs http://cxf.apache.org/schemas/blueprint/jaxrs.xsd
http://cxf.apache.org/blueprint/core http://cxf.apache.org/schemas/blueprint/core.xsd
http://camel.apache.org/schema/blueprint http://camel.apache.org/schema/blueprint/camel-blueprint.xsd
">

    <camelContext id="goochjs-cameltest-customer" trace="false" xmlns="http://camel.apache.org/schema/blueprint">

        <route id="jetty">
            <from uri="jetty:http://0.0.0.0:8892/rest?matchOnUriPrefix=true" />
            <log logName="goochjs" loggingLevel="INFO" message="Request received 1: ${body}" />
            <to uri="cxfbean:customerResource" />
        </route>
    </camelContext>

    <bean id="customerResource" class="org.goochjs.cameltest.CustomerResourceImpl" />
</blueprint>

...和我的资源类...

package org.goochjs.cameltest;

import javax.ws.rs.Consumes;
import javax.ws.rs.DefaultValue;
import javax.ws.rs.GET;
import javax.ws.rs.POST;
import javax.ws.rs.Path;
import javax.ws.rs.PathParam;
import javax.ws.rs.Produces;
import javax.ws.rs.QueryParam;
import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;

@Produces({ MediaType.APPLICATION_XML, MediaType.APPLICATION_JSON })
@Consumes({ MediaType.APPLICATION_XML, MediaType.APPLICATION_JSON })
@Path("/customers")
public class CustomerResourceImpl {

    @POST
    @Path("/{type}")
    public Response newCustomer(Customer customer, @PathParam("type") String type, @QueryParam("active") @DefaultValue("true") boolean active) {
        return Response.ok(type).build();
    }

    @GET
    @Path("/{type}")
    public Response getCustomer(@PathParam("type") String type) {
        Customer output = new Customer();
        output.setId(987654);
        output.setName("Willy Wonka");

        return Response.ok(output).build();
    }
}

最后,这是我的示例 XML:-

<?xml version="1.0" encoding="UTF-8"?>
<Customer>
    <name>Willy Wonka</name>
    <id>987654</id>
</Customer>

感谢您的任何指示。如果更容易查看,整个项目都打包在我的 github 站点上

J。

4

1 回答 1

0

经过几个小时的挠头,我已经解决了这个问题。问题是没有消息体被呈现给资源类。在我添加streamCache="true"到 Camel XML 中的路由节点后,它开始工作。

这是 Camel 网站上的相关页面 - http://camel.apache.org/stream-caching.html

我认为使用cxfrs://作为来自端点的模式隐含地做到了这一点。但是,我无法让它在 Blueprint XML 中工作,这就是我预先部署 Jetty 的原因。

J。

于 2013-04-23T15:40:44.450 回答