WSDL 对 Camel 和 CXF 的响应

Question

虽然我已经与他们互动多年，但我对WSDL设计非常陌生。我有一个 WSDL，我正在尝试与 Camel 一起使用

我试图实现的是对SOAP客户端的自定义响应字符串，并将SOAP请求转换为JSON，并将其推送到websocketsendpoint。

我的WSDL模式在代码生成时生成响应类，但是响应似乎从来没有在调试器中被调用过。

此外，如果我删除Camel中的json转换器，整个soap请求将返回给SOAP客户端，如果我将转换器留在里面，它会变得不高兴，因为它期待的是XML，而它得到的是json blob。

 <cxf:cxfEndpoint id="position-ws"
                 address="/positions"
                 endpointName="c:PositionsPort"
                 serviceName="c:PositionsService"
                 serviceClass="com.company.finance.positions.PositionsImpl"
                 xmlns:c="http://positions.finance.company.com/">
    <cxf:properties>
        <entry key="schema-validation-enabled" value="true"></entry>
    </cxf:properties>
                 </cxf:cxfEndpoint>

<camelContext id="camel" xmlns="http://camel.apache.org/schema/spring">
    <dataFormats>
        <xmljson id="xmljson"/>
        <xmljson id="xmljsonWithOptions" forceTopLevelObject="true" trimSpaces="true" rootName="newRoot" skipNamespaces="true"
                 removeNamespacePrefixes="true" expandableProperties="d e"/>
    </dataFormats>

    <route>
        <from uri="cxf:bean:position-ws?dataFormat=PAYLOAD"/>
        <convertBodyTo type="String"></convertBodyTo>
        <to uri="log:com.mycompany.order?level=DEBUG"/>
        <process ref="xmlTransformProcessor"/>
        <to uri="log:com.mycompany.order?level=DEBUG"/>
        <to uri="websocket:positionsTopic?sendToAll=true"/>

    </route>
</camelContext>

<bean id="xmlTransformProcessor" class="com.company.finance.positions.XMLTransformer"/>

XML到Json转换器

public class XMLTransformer implements Processor {

public void process(Exchange exchange) throws Exception {

    String data = exchange.getIn().getBody(String.class);


    JSONObject jsonObj = XML.toJSONObject(data);
    String json = jsonObj.toString();

    // use regular java code to transform to a better form
    //exchange.getIn().setBody(json);
    exchange.getOut().setBody(json);
}

}

所以我的问题是，使用Camel，我如何返回自定义响应字符串“Okay”、“Not Okay”等，同时将其余数据推到路线的另一步？

谢谢

Answer 1

谜团解开了。

我需要这样的东西：

 <route>
        <from uri="cxf:bean:position-ws"/>
        <to uri="log:com.mycompany.order?level=DEBUG"/>
        <convertBodyTo type="com.company.finance.positions.PositionSummary"/>
        <marshal>
        <jaxb contextPath="com.meteoriteconsulting.finance.positions"
        partClass="com.company.finance.positions.NewEntry"
        fragment="true"
        partNamespace="{http://com.company}NewEntry" />
        </marshal>
        <process ref="xmlTransformProcessor"/>
        <to uri="log:com.mycompany.order?level=DEBUG"/>
        <to uri="websocket:positionsTopic?sendToAll=true"/>
        <transform>
            <constant>OK</constant>
        </transform>

    </route>