使用JDBC存储库的Idempotent使用者Apache Camel

Question

我正在使用Apache Camel使用springboot，所以我的问题是我该如何编写代码才能使用Idempotentconsumer和使用apache骆驼的JDBC存储库。

Answer 1

所有你需要做的是从camel-sql

实施AbstractJdbcMessageIdRepository

#queryForInt(T key) 
#insert(T key) 
#delete(T key) 

方法定义你的bean

<bean id="idempotentRepository" 
      class="yourpackage.YourJDBCIdempotentRepository"> 
     <property name="dataSource" ref="your-datasource-bean-ref"/> 
    </bean> 

加入航线

<route id="your-route"> 
     <from uri="ftp:your-endpoint?idempotent=true&idempotentRepository=#idempotentRepository"/> 
     ... 
    </route> 

参考：http://camel.apache.org/maven/camel-2.10.0/camel-sql/apidocs/org/apache/camel/processor/idempotent/jdbc/AbstractJdbcMessageIdRepository.html