0
我正在使用Apache Camel使用springboot,所以我的問題是我該如何編寫代碼才能使用Idempotentconsumer和使用apache駱駝的JDBC存儲庫。使用JDBC存儲庫的Idempotent使用者Apache Camel
我正在使用Apache Camel使用springboot,所以我的問題是我該如何編寫代碼才能使用Idempotentconsumer和使用apache駱駝的JDBC存儲庫。使用JDBC存儲庫的Idempotent使用者Apache Camel
所有你需要做的是從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>