Camel Reslet和CXF SOA集成问题

Question

我是骆驼的新手，并且面临着需要设置的路线问题。如果有人可以引导我到正确的论坛，或者更好地纠正我面临的问题，那就太好了。这是我需要做的 - 公开一个 restlet endpoint来接受数据;使用此数据作为外部 SOAP Web 服务的输入，并以 JSON 格式将响应发送回调用方...这是我所做的...但是，当Camel尝试调用Web服务时，我收到以下错误...谁能指导我到这里？谢谢。

我使用的是camel 2.11.1和cxf codegen插件2.7.11版

我得到以下异常:org.restlet.data.Parameter不能转换为java.lang.String。

    public class IntegrationTest extends CamelTestSupport { 

String restletURL = <url>;

    @org.junit.Test 
    public void integTest() throws Exception { 
    //trying to simulate the rest service call... 
  template.sendBodyAndHeader(restletURL, "Body does not matter here", "data", "{\"FromCurrency\":\"AUD\",\"ToCurrency\":\"USD\"}"); 

    } 


    @Override 
    protected RouteBuilder createRouteBuilder() throws Exception { 
        return new RouteBuilder() { 
            @Override 
            public void configure() throws Exception { 
            System.out.println("In Counfigure"); 

        String cxfEndpoint = "cxf://http://www.webservicex.net/CurrencyConvertor.asmx?" 
        + "wsdlURL=http://www.webservicex.net/CurrencyConvertor.asmx?wsdl&" 
        + "serviceName={http://www.webserviceX.NET/}CurrencyConvertor&" 
        + "portName={http://www.webserviceX.NET/}CurrencyConvertorSoap&" 
        + "dataFormat=MESSAGE"; 

        XmlJsonDataFormat xmlJsonFormat = new XmlJsonDataFormat(); 
        SoapJaxbDataFormat soap = new SoapJaxbDataFormat("net.webservicex", new ServiceInterfaceStrategy(CurrencyConvertorSoap.class, true)); 

         GsonDataFormat gson = new GsonDataFormat(ConversionRate.class); 
         gson.setFieldNamingPolicy(FieldNamingPolicy.UPPER_CAMEL_CASE);

from(restletURL).routeId("Restlet") 
                                .process(new Processor() { 
                                        @Override 
                                        public void process(Exchange exchange) throws Exception { 
                                                String data = (String) URLDecoder.decode((String) exchange.getIn().getHeader("data"), "UTF-8"); 
                                                System.out.println(data); 
                                                // get the mail body as a String 
                                                exchange.getIn().setBody(data); 
                                                Response.getCurrent().setStatus(Status.SUCCESS_OK); 
                                } 

                                }) 
                .unmarshal(gson) 
                .marshal(soap) 
                .log("${body}") 
                .to(cxfEndpoint) 
                .unmarshal(soap) 
                .marshal(xmlJsonFormat); 
                .log("${body}"); 
            } 
        }; 
    } 
}

但是，当我尝试单个部分时，该示例有效 - 单独的 restlet 和单独的 CXF......

谢谢，里特维克。

Answer 1

我面临的问题已经解决了。除了“exchange.getIn（）. setbody（data）；”之外，我还添加了以下代码行“exchange.getIn（）. sethead er（org.restlet.http.headers ", "");" 为了摆脱我得到的类强制转换异常。reslet标头导致了这个问题，一旦这些标头被删除（我一开始不需要标头），一切都按预期工作。

谢谢，里特维克。

Answer 2

当然，威廉，这是整个配置实现:

@Override
public void configure() throws Exception {
        String restletURL = "restlet:http://localhost:8080/convert/{data}?restletMethods=get";

        String cxfEndpoint = "cxf://http://www.webservicex.net/CurrencyConvertor.asmx?"
                + "portName={http://www.webserviceX.NET/}CurrencyConvertorSoap&"
                + "dataFormat=MESSAGE&loggingFeatureEnabled=true&defaultOperationName=ConversionRate&defaultOperationNamespace={http://www.webserviceX.NET/}&synchronous=true";


        SoapJaxbDataFormat soap = new SoapJaxbDataFormat("net.webservicex", new ServiceInterfaceStrategy(CurrencyConvertorSoap.class, true));
        soap.setVersion("1.2");

        GsonDataFormat gson = new GsonDataFormat(ConversionRate.class);
        gson.setFieldNamingPolicy(FieldNamingPolicy.UPPER_CAMEL_CASE);

        from(restletURL).routeId("Restlet")
        .process(new Processor() {
            @Override
            public void process(Exchange exchange) throws Exception {
                String data = (String) URLDecoder.decode((String) exchange.getIn().getHeader("data"), "UTF-8");
                exchange.getIn().setHeader("org.restlet.http.headers", "");
                exchange.getIn().setHeader("data", "");
                exchange.getIn().setBody(data);
                Response.getCurrent().setStatus(Status.SUCCESS_OK);
            }

        })
        .unmarshal(gson)
        .marshal(soap)
        .to(cxfEndpoint)
        .unmarshal(soap)
        .marshal(gson)
        .process(new Processor() {
            public void process(Exchange exchange) throws Exception {
                String output = exchange.getIn().getBody(String.class);
                exchange.getOut().setBody(output);
            }
        });
    }