具有并行处理的Apache camel多播不会将异常传播到死信处理程序

Question

我有骆驼路线。

from(errorMultiDirect).routeId("errorMulticastTest")
    .errorHandler(deadLetterChannel(mock)
                .onPrepareFailure(errorProcessor).maximumRedeliveries(0))
    .log(LoggingLevel.INFO, "Testing Error route")
    .setHeader(OrderMessageConstants.WIMS_MSG_TYPE, simple("body[messageType]"))
    .setHeader(OrderMessageConstants.SAP_MESSAGE_ID, simple("body[messageID]"))
    .setHeader(OrderMessageConstants.ORDER_NUMBER, simple("body[orderHeader][order]"))
    .multicast().parallelProcessing().shareUnitOfWork().stopOnException().to("direct:materialsTest", "direct:qmDocTest", "direct:sdsTest").end()
    .to("log:com.sial.NotifyStatusLogger?level=INFO");

如果异常发生在任何组播路由中，如materaialsTest，则异常会被捕获在组播代码中，但异常不会被发送到死信通道。根据文档，设置shareUnitOfWork应该可以实现这一点，但它没有，设置StoponException也没有。我是不是漏掉了什么？

from(errorDirect).routeId("errorMaterialTest")
    .errorHandler(deadLetterChannel(mock)
                .onPrepareFailure(errorProcessor).maximumRedeliveries(0))
    .log(LoggingLevel.INFO, "Testing Error route")
    .setHeader(OrderMessageConstants.WIMS_MSG_TYPE, simple("body[messageType]"))
    .setHeader(OrderMessageConstants.SAP_MESSAGE_ID, simple("body[messageID]"))
    .setHeader(OrderMessageConstants.ORDER_NUMBER, simple("body[orderHeader][order]"))
    .bean(materialsEnrichment)
    .to("log:com.sial.NotifyStatusLogger?level=INFO");

当materialsEnrichment bean抛出异常时，第二条路由将消息发送到死信通道。这与组播路由通过“direct：materialstest”调用的bean相同。

Answer 1

您需要关闭直接路由中的错误处理，因为死信通道仅在您的路由中被配置为路由范围内的错误处理程序。则直接路由的故障应由组播路由处理。

from("direct:xxx")
  .errorHandler(noErrorHandler())