Aapche-Camel在每次重试时保存错误信息

Question

我有一个Apache Camel路由，它处理队列中的消息。为了更好地理解运行时发生的事情，我还将执行状态保存在数据库中（重试次数、上次执行状态、...)。我想使用异常处理程序中的重新传递机制，但它对每次更新数据库记录的失败都执行一些处理。

from("jms:myinputqueue")
    .onException(RetriableException.class)
        .maximumRedeliveries(5)
        .maximumRedeliveryDelay(10000)
        .useOriginalMessage()
        .to("log:store error information in database about each attempt") // (1)
        .end() // onException
    .to("log:apply business logic here which can throw exceptions")
;

Answer 1

您可以使用onexceptionAccessed处理器，在异常发生时调用该处理器。

它包含在Camel 2.17之后:https://issues.apache.org/jira/browse/Camel-9069