拆分后从骆驼路线获取原始消息

Question

我有一个骆驼路由，它从队列中批量读取消息，处理消息并继续将它们一一发送到 api 并等待 api 响应。

当引发 500 响应时，我在检索开始时收到的原始消息时遇到问题。

我以为拆分器会返回原始消息？

这是我的路线：

    from(gatewayRouteConfig.getInputQueueEndpoint())
            .process(process1)
            .process(process2)
            .setExchangePattern(ExchangePattern.InOnly)
            .choice()
            .when().jsonpath("Message", true)
            .setBody(MESSAGE_WRAPPER_EXTRACTOR)
            .end()
            .split().method(messageSplitter, "splitMessages")
            .log(INFO, "Received Message : ${body}")
            .process(process3)
            .process(validate)
            .process(identity)
            .process(requestProcessor) //where the exception is thrown and the original message that is used in the exception handler is picking up
            .process(someService::gatewayResponseTimeStop)
            .process(someService::endToEndResponseStop)
            .process(someService::markGatewayDeliveryAsSuccess)
            .log("Completed processing...");

这是我在同一个类中的异常处理程序：

    private void configureExceptionHandlers() {

        onException(ProviderException.class) //thrown when 500 error occurs
            .useOriginalMessage() //picks message in the form the process(requestProcessor) method recieves it instead of start of route
            .handled(true)
            .log(ERROR, LOGGER, EXCEPTION_MESSAGE_WITH_STACKTRACE)
            .to(DLQ);

Answer 1

通过添加shareUnitOfWork解决

.split().method(activityMessageSplitter, "splitActivityMessages").shareUnitOfWork()