使用SOAPendpoint的Apache Camel节流-> TransformerException

Question

我们有一个提供SOAP服务的ApacheCamel应用程序。“初始路由”从Apache CFX提供的endpoint开始。

我们需要一个简单的机制来防止消息处理得“太快”（并且没有大量的可扩展性需求）。

因此，我们最终尝试了Throttler。现在，问题是在我们的路线上加了油门后，出了问题。

最初的路线，有点干净：

from("cxf:bean:sapEndpoint").routeId(SOAP_ENDPOINT)
    .throttle(1)
    .onException(Exception.class)
        .to("direct:emailFaultNotification").handled(false)
    .end()
    .transacted(joinJpaTx)
    .to(xsltRemoveEmptyElements) // Cleaning done with XSLT endpoint
    .to("direct:inboundWorkOrderXml"); // Forward to actual processing

// direct:inboundWorkOrderXml contains various validation, persistance & response

我们日志中的错误:

2013-02-18 16:50:16,257 [tp1636587648-50] ERROR DefaultErrorHandler            - Failed delivery for exchangeId: ID-...-4. Exhausted after delivery attempt: 1 caught: javax.xml.transform.TransformerException: javax.xml.transform.TransformerException: com.sun.org.apache.xml.internal.utils.WrappedRuntimeException: Content is not allowed in prolog.
javax.xml.transform.TransformerException: javax.xml.transform.TransformerException: com.sun.org.apache.xml.internal.utils.WrappedRuntimeException: Content is not allowed in prolog.
    at com.sun.org.apache.xalan.internal.xsltc.trax.TransformerImpl.transform(TransformerImpl.java:735)[:1.6.0_37]
    at com.sun.org.apache.xalan.internal.xsltc.trax.TransformerImpl.transform(TransformerImpl.java:336)[:1.6.0_37]
    at org.apache.camel.builder.xml.XsltBuilder.process(XsltBuilder.java:98)[camel-core-2.7.0.jar:2.7.0]
    at org.apache.camel.impl.ProcessorEndpoint.onExchange(ProcessorEndpoint.java:102)[camel-core-2.7.0.jar:2.7.0]
    at org.apache.camel.impl.ProcessorEndpoint$1.process(ProcessorEndpoint.java:72)[camel-core-2.7.0.jar:2.7.0]
    ...

我想油门没有按我想象的那样正常工作。

似乎启用限制后，XSLT endpoint会收到空或无效的 XML？没有油门定义，一切正常。经过短暂的尝试，消息正文似乎仍然包含XML字符串？

一些想法？

Answer 1

最后，解决方案比我想象的要简单。我没有在从“cxf：bean：sapEndpoint”开始的路由中使用限制，而是在路由处理“direct：inboundWorkOrderXml”中添加了限制。

不知道确切的原因，可能与油门功能的某些部分可能与路线的起点有关。（因此，直接endpoint未遇到cxfendpoint的问题）

Answer 2

使用Camel错误处理进行重新交付时，请注意流有效负载。查看流缓存：http://camel.apache.org/stream-caching.html

在 Camel CXF 文档页面的顶部还有一个提示：http://camel.apache.org/cxf 关于这个