JDBC 저장소의 멱등 한 소비자 Apache Camel

Question

나는 Apache Camel에서 springboot로 작업하고있다. 그래서 나의 질문은 apache camel을 사용하는 JDBC 저장소와 함께 Idempotentconsumer를 사용하는 코드를 작성하는 방법이다.

Answer 1

당신이해야 할 모든 경로에 추가

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

여러분의 빈 정의 camel-sql

에서 AbstractJdbcMessageIdRepository의

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

메소드를 구현이다

<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