异常后更新骆驼交换体，继续路线

Question

希望你有时间回答我的问题。在过去的几天里，我一直在阅读关于Camel的文章，并设法将一切都设置好并运行起来。现在，我碰到了一个棘手的部分:)。基本上，我在运行时使用Java定义一个路由，并将路由配置放在DB中。路线是可行的，信息从一边流向另一边。但是，当异常发生时，我想知道异常发生在哪里(在哪个路由endpoint之间)，在DB中html" target="_blank">存储当前的交换主体(对进一步处理有用的进行中的消息)，由用户更新消息，然后从异常点(它失败的地方)重试路由执行。假设所有路由步骤都是幂等的。

我的解决方案：

1. 为路由创建拦截器
将
2. 路线尽可能多地切成颗粒（每个新步骤都是一条新路线）
3. 在每个步骤之间，使用当前和未来步骤以及当前交换机构更新数据库
4. 如果发生异常，请将消息存储在 DB 中，使用编辑器进行更新
5. 使用生产者模板将消息发送到下一个路由点（取自 DB）

对此，你怎么看？这是可行的还是骆驼不能用这种方法支持我？

感谢您的耐心等待和抽出宝贵时间。希望我足够清楚。

Answer 1

您应该使用< code>onException()子句来解决这个问题。例如:

public void configure() throws Exception{
  //This is a global onException definition and will work for all routes defined in this calss
    onException().process(new Processor(){
        public void process(Exchang arg0){
            Exception e = arg0.getProperty(Exchange.EXCEPTION_CAUGHT,Exception.class);
            //get message and other properties that you  are interested in 
            db.saveOrUpdate(/*Pass your custom object here*/); 
        }

    }).handled(true);

   from("direct:route1")
   //some processing
   .to("jms:route1");

   from("direct:route2")
   //some processing
   .to("http://route2");

}

您可能需要在apache骆驼站点上查阅确切的详细信息，因为我刚刚在这里编写了此代码。

Answer 2

您可以使用骆驼的示踪剂组件。骆驼网站上已经提供了满足您需求的详细示例：http://camel.apache.org/tracer-example.html