Camel route，如何使用endpoint作为触发器，返回即时响应但继续流程？

Question

我想用骆驼实现一种触发EIP。

我想要的是:我有一个web服务，它将充当骆驼路线的endpoint。这个服务接收一个请求，如果请求是格式良好的，它必须并行做两件事:用一个简单的消息“OK”或“ACK”向原始发送者返回一个响应，或者如果请求不是格式良好的，响应将是“NOK”或“RPT”(请求重复消息)。与此同时，如果消息是格式良好的，那么它必须被发送到另一个web服务，该web服务将使用一些信息来丰富原始消息，并将结果消息(或交换，我不确定这里的术语是否正确)发送到JMS实现。

我的endpoint充当进程的触发器，但必须立即向调用者返回响应。

所以我的问题是，我可以使用什么组件来做到这一点？我正在使用Spring DSL实现路由。我开始使用：

<route>
  <from uri="cxf:bean:clientEventEip?dataFormat=MESSAGE"/>
  <multicast>
    <to uri="bean:messageResponse"/><!-- checks the message and returns 'OK' -->
    <to uri="bean:messageEnricher"/><!-- Enriches and sends msg to another WS -->
  </multicast>
</route>

但是我在客户端得到一个错误响应:

<soap:Envelope xmlns:soap="http://schemas.xmlsoap.org/soap/envelope/">
   <soap:Body>
      <soap:Fault>
         <faultcode>soap:Server</faultcode>
         <faultstring>Exception occurred during execution on the exchange: Exchange[Message: [Body is instance of java.io.InputStream]]</faultstring>
      </soap:Fault>
   </soap:Body>
</soap:Envelope>

在IDE中有很多例外，比如:

org.apache.camel.CamelExecutionException

和

 org.apache.camel.InvalidPayloadException: No body available of type: org.w3c.dom.Document but has value: org.apache.cxf.transport.http.AbstractHTTPDestination$1@b8c6fb of type: null on: Message: [Body is instance of java.io.InputStream]. Caused by: Error during type conversion from type: null to the required type: org.w3c.dom.Document with value org.apache.cxf.transport.http.AbstractHTTPDestination$1@b8c6fb due org.xml.sax.SAXParseException; lineNumber: 1; columnNumber: 1; Premature end of file.. Exchange[Message: [Body is instance of java.io.InputStream]]. Caused by: [org.apache.camel.TypeConversionException - Error during type conversion from type: null to the required type: org.w3c.dom.Document with value org.apache.cxf.transport.http.AbstractHTTPDestination$1@b8c6fb due org.xml.sax.SAXParseException; lineNumber: 1; columnNumber: 1; Premature end of file.]

如果我只是在我的骆驼路线中使用其中一颗豆子，一切顺利，响应是我期望的。

我确信这是我的错误，我肯定使用了错误的组件，但我仍然没有找到解决方法，我感谢任何人能给我的帮助！

Answer 1

您是否研究过骆驼提供的Wiretap模式：

http://camel.apache.org/wire-tap.html

窃听本质上是获取交换的副本，并异步路由到不同的endpoint。上面的链接有更多详细信息。

您可以检查您的消息，如果没问题，您可以同时调用窃听endpoint和响应endpoint。像这样：

<route>
  <from uri="cxf:bean:clientEventEip?dataFormat=MESSAGE"/>

    <wireTap uri="direct:tap"/>      

    <to uri="bean:messageResponse"/><!-- checks the message and returns 'OK' or 'NOK'-->

</route>

<route>
   <from uri="direct:enrichingRoute"/>
   <to uri="bean:messageEnricher"/><!-- Enriches and sends msg to another WS -->
</route>

在调用窃听器之前，您可能需要添加一个过滤器来检查错误，但我认为窃听 EIP 应该为您指明正确的方向。

干杯尤格什