Camel读取文件，并在出现异常时将文件移动到错误文件夹

Question

我正在使用camel从. csv文件中读取一些记录，用Bindy转换它们并将它们保存在db中。但是，当发生错误时，例如在取消管理或从文件中持久化一行时，我想停止对文件的处理并将其移动到不同的目录。我的路线如下，我使用Spring启动camel 3.7版本

onException(Exception.class)
            .handled(true)
            .log(LoggingLevel.INFO, "${file:name}")
            .log("IOException occurred due: ${exception.message}")
            .useOriginalMessage()
            .toD("file://".concat(targetErrorLocation).concat("/${file:name}"))
            .end();


    from(buildPathUrl())
            .transacted()
            .log(LoggingLevel.INFO, "${file:name}")
            .choice()
            .when(header("CamelFileName").contains("ORDER"))
            .log(LoggingLevel.INFO, "Order file")
            .to("direct:orderRoute")
            .when(header("CamelFileName").contains("TRANSACTIONS"))
            .log(LoggingLevel.INFO, "Transaction file")
            .to("direct:transactionRoute")
            .when(header("CamelFileName").contains("BATCH"))
            .log(LoggingLevel.INFO, "Shipment batch file")
            .to("direct:shipBatchRoute")
            .otherwise()
            .log(LoggingLevel.INFO, "Shipment file")
            .to("direct:shipmentRoute");


    from("direct:orderRoute")
            .log(LoggingLevel.INFO, "${body}")
            .unmarshal(orderCsvDataFormat)
            .log(LoggingLevel.INFO, "${file:name}")
            .split(body())
            .streaming()
            .shareUnitOfWork()
            .log(LoggingLevel.INFO, "${body}")
            .to("bean:ordersService?method=persistOrder")
            .end();

   private String buildPathUrl() {
    StringBuilder stringBuilder = new StringBuilder("file://");
    stringBuilder.append(sourceLocation)
            .append("?move=")
            .append(targetLocation)
            .append("/")
            .append("${file:name}")
           /* .append(AMPERSAND)
            .append("bridgeErrorHandler=true")*/
            .append(AMPERSAND)
            .append("moveFailed=error/${file:name}")
            /*.append(AMPERSAND)
            .append("delete=true")*/;

    return stringBuilder.toString();

}

到目前为止，当出现异常时，处理停止，但文件不会移动到错误目录，而是移动到已成功处理的文件所在的目录。我将感激任何帮助。提前感谢。

Answer 1

您是否尝试过仅删除错误处理程序？

文件使用者选项< code>move和< code>moveFailed应该可以满足您的要求。

当文件使用者收到异常时，它会将文件移动到moveFailed位置，否则会将其移动到标准move。

看看你的路线，这应该很好direct路由是同步的内部调用，因此异常会跨路由传播。

但是，您的错误处理程序会捕捉任何异常(< code>Exception.class)并处理它们(< code>handled(true))。

因此，文件使用者不会再收到异常。它假定处理成功，并将文件移动到标准移动位置。