apache-camel - 具有 JDBC 存储库 Apache Camel 的幂等消费者

Question

我正在使用 Apache Camel 开发 springboot，所以我的问题是我如何编写代码以使用 Idempotentconsumer 和 JDBC 存储库使用 Apache Camel。

Answer 1

您需要做的就是实施

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

AbstractJdbcMessageIdRepository从方法camel-sql

定义你的 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