Consommateur idempotent avec le référentiel JDBC Apache Camel

Question

Je travaille sur springboot avec Apache Camel alors ma question est comment puis-je écrire du code pour utiliser Idempotentconsumer avec le référentiel JDBC en utilisant apache camel.

Answer 1

Tout ce que vous devez faire est de mettre en œuvre

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

méthodes de AbstractJdbcMessageIdRepository de camel-sql

définir votre haricot

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

ajouter dans l'itinéraire

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

Référence: http://camel.apache.org/maven/camel-2.10.0/camel-sql/apidocs/org/apache/camel/processor/idempotent/jdbc/AbstractJdbcMessageIdRepository.html