Idempotent Verbraucher mit JDBC-Repository Apache Camel

Question

Ich arbeite auf Springboot mit Apache Camel, so meine Frage ist, wie kann ich Code schreiben, um Idempotentconsumer mit JDBC-Repository mit Apache Kamel zu verwenden.

Answer 1

Alles, was Sie tun müssen, ist implementieren

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

Methoden der AbstractJdbcMessageIdRepository von camel-sql

definieren Sie Ihre Bohne

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

in Route hinzufügen

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

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