Camel sql错误处理

Question

我的任务是处理路由中所有传入的消息，并将它们保存到数据库中。我的路由从webservice（camel cxf）开始，然后处理到ejb并返回soap响应。

我决定使用驼峰sql组件。就我在记录传入消息方面没有任何问题而言：

<camelContext id="InstitutionContext" xmlns="http://camel.apache.org/schema/spring">

    <onException>
        <exception>org.example.MyException</exception>
        <continued><constant>true</constant></continued>
        <to uri="bean:myExceptionHandler?method=handle" />
    </onException>

    <route id="InstitutionRoute" >
        <from uri="direct:start" />
        <to uri="sql:insert into translog(id,type,data) values(2,'IN',#)" />
        <split>
            <tokenize token="\n" />
            <unmarshal>
                <csv delimiter=";" />
            </unmarshal>
            <process ref="InstitutionProcessorTest" />
        </split>
        <to uri="bean:myExceptionHandler?method=checkErrors" />
    </route>

</camelContext>

但是我不知道如何处理异常并以SOAP消息的形式保存它们。

<onCompletion onFailureOnly="true">
    <to uri="sql:insert into translog(id,type,data) values(2,'ERROR',#)" />
</onCompletion> 

但它将原始消息保存在数据列中。有谁能帮忙吗？

Answer 1

我可能误解了这个问题，但如果出现异常，您似乎正在尝试以XML格式保存SOAP消息。

默认情况下，CXF的dataFormat是POJO，这意味着它在骆驼路线周围发送一个POJO，即SOAP XML被转换为POJO。

我想到了两个选择：

1. 将dataformat设置为message或payload。这将通过驼峰路径而不是POJO发送XML消息
2. 将POJO整理成XML消息并保存