路线内的骆驼路线上下文无限执行

Question

我的Apache骆驼项目开始有一个相当好的结构，但我陷入了困境，因为我的routeContext中的路由无限执行。我的所有路由都使用SQL组件，我希望所有路由只执行一次。

我发现，当我的routeContext中有两条路由时，两条路由都只执行一次，但是一旦我添加了第三条路由（不管第三条路由是什么），camel就开始无限执行所有路由。我所有的路由都导致sql插入，因此相同的路由运行多次会导致重复键错误。

我认为这可能是我的一条路线中的一个错误，但是我已经尝试改变etc的顺序，每次我在我的routeContext中从两条路线切换到三条路线时，问题又出现了。今晚，我还试图将路线分成不同的路线环境，但这并没有改变什么。我还取出了所有的错误处理程序，以确保它与它们无关。

我开始认为这是 Camel 中 sql 组件的错误。大家的想法是什么？我应该切换到其他组件（例如 jdbc）吗？

下面是我的xml文件的样子...

骆驼语境

<import resource="camel-routes.xml"/>
<import resource="database.xml"/>       

<camel:camelContext trace="true">   
  <camel:propertyPlaceholder location="classpath:sql.properties" id="placeholder"/>
  <camel:routeContextRef ref="sourceToStaging"/>
</camel:camelContext>

骆驼路线

<routeContext id="sourceToStaging" xmlns="http://camel.apache.org/schema/spring">
<route id="processTypeOption-route">    
    <from uri="sourceSql:{{sql.selectTypeOption}}"/>
    <transacted/>           
    <to uri="targetSql:{{sql.insertTypeOptionOrig}}"/>                          
    <to uri="targetSql:{{sql.insertTypeOptionStg}}"/>                       
    <to uri="controlbus:route?routeId=processTypeOption-route&amp;action=stop&amp;async=true"/>
</route>

<route id="processProductSize-route">    
    <from uri="sourceSql:{{sql.selectProductSize}}"/>
    <transacted/>           
    <to uri="targetSql:{{sql.insertProductSizeOrig}}"/>                             

    <to uri="targetSql:{{sql.insertProductSizeStg}}"/>                     
    <to uri="controlbus:route?routeId=processProductSize-route&amp;action=stop&amp;async=true"/>
</route>                
<route id="processStatus-route">    
    <from uri="sourceSql:{{sql.selectStatus}}"/>
    <transacted/>           
    <to uri="targetSql:{{sql.insertStatusOrig}}"/>                              
    <to uri="targetSql:{{sql.insertStatusStg}}"/>                       
    <to uri="controlbus:route?routeId=processStatus-route&amp;action=stop&amp;async=true"/>
</route>                        
</routeContext> 

有人能帮忙吗？谢谢

Answer 1

我也有过类似的情况。但是线程在加载 Camel 上下文时无限执行。尝试在到达endpoint后从交换标头中删除 CamelHttp*。