我正在使用Apache camel开发springboot,所以我的问题是如何编写代码来使用Idempotentconsumer和使用apache Camel的JDBC存储库。
发布于 2016-11-14 11:18:02
您所需要做的就是实现
#queryForInt(T key)
#insert(T key)
#delete(T key)
camel-sql
中的AbstractJdbcMessageIdRepository
方法
定义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>
https://stackoverflow.com/questions/40502194
复制相似问题