多个camel路由之间的数据库事务

Question

事务如何在带有Spring DSL的骆驼路由中工作，并且其中一条路由抛出异常？

如果routeB抛出异常，将如何将异常传播回RouteA。

如果在routeB中抛出异常，我可以看到TransactionalErrorHandler正在处理异常并回滚事务。

我的骆驼路由定义：

<route id="routeA">
  <from uri="direct-vm:endpointA" />
  <transacted />
  <to uri="direct-vm:endPointB" />
  <bean ref="beanA" method="save" />
  <onException>
    <exception>java.lang.Exception>
    <handled><constant>true</constant></handled>
    <bean ref="beanA" method="handleError" />
    <rollback markRollbackOnly="true" />
  </onException>
</route>

<route id="routeB">
  <from uri="direct-vm:endPointB" />
  <throwException ref="ex"/>
</route>

Answer 1

在camel中，Transacted命令只是SpringTransactionTemplate的包装器，因为它将在PlatformTransactionManager提供的事务中登记路由。您在org.apache.camel.spring.spi.SpringTransactionPolicy上获得的唯一配置选项是传播行为，因此处理回滚等必须在事务路由中完成。

在这种情况下，您应该从路由B捕获异常，如果它到达错误处理程序，那么就太晚了。

<route id="routeA">
    <from uri="direct-vm:endpointA" />
    <transacted/>
    <doTry>
        <to uri="direct-vm:endPointB" />
        <doCatch>
           <exception>java.lang.Exception</exception>
           <bean ref="beanA" method="handleFail"/>
        </doCatch>
        <doFinally>
           <bean ref="beanA" method="save" />
        </doFinally>
    </doTry>
</route>

<route id="routeB">
    <from uri="direct-vm:endPointB" />
    <throwException ref="ex"/>
</route>