代码之家 › 专栏 › 技术社区 › isy

camel-使用拆分运算符处理异常

activemq apache-camel exception

isy · 技术社区 · 8 年前

我用一个订单/项目示例简化了我的用例。

订单中有一些项目。每个项都受控制=>可以从“controlItem”中引发AvailabilityException。抛出异常后,项被标记为OK,并处理下一项。

       onException(AvailabilityException.class)
           .onExceptionOccurred(ItemProcessor)
           .handled(true)
       .bean(service, "markAsOk");


       from(startQueue)
           .split(simple("${body.items}"))
                .to(direct:controlItem")                                            
           .end()
       .to(successQueue);


       from("direct:controlItem")
           .bean(service, "controlItem");

现在我有另一个案例:

当抛出意外异常(NullPointerException,…)时,我希望停止进程。我们不处理下一个项目,订单被重定向到错误队列。我该怎么做?

1 回复 | 直到 8 年前

pvpkiran 8 年前

doTry doCatch

from(startQueue)
  .doTry()
     .split(simple("${body.items}"))
            .to(direct:controlItem")                                            
       .end()
     .to(successQueue);
  .doCatch(AvailabilityException.class)
          ....
          ....
          .handled(true)
   .doCatch(RunTimeException.class)
          ....
          ....
          .handled(false)
          .stop() // stop the execution      
   .doFinally()  //optional

stop() exchange.getContext().stop();
onException RunTimeException
exchange.setProperty(Exchange.ROUTE_STOP, Boolean.TRUE);

推荐文章

TSSK · org.apache.camel.springboot适用于弹簧靴3.3.0的camel-bindy和cameljackson版本

2 年前

manish2aug · Apache Camel Springboot测试:断言错误:mock://checks收到的消息计数。预期:<1>,但实际为:<0>

2 年前

ÐÐ»ÐµÐºÑÐµÐ¹ · apache camel增量版本后出现ClassNotFoundException异常

2 年前

kilobyte · Apache Camel与Google PuSub的集成

3 年前

DummyGuy · 将JSON数组转换为对象数组-Apache camel

4 年前

silenzzz · 找不到骆驼码头终结点

4 年前

jbabu · ApacheCamel——返回值的组件

4 年前

Mawillec · 在一个消费者隐藏多个用户的情况下,在队列中保留和锁定消息的策略

8 年前

Giulio Pulina · ActiveMQ 5.9-由于未释放锁,代理上的线程被阻止

8 年前

Sparkler-blush · 驼峰http获取调用状态代码406

8 年前