326.14. JDBC 기반 집계 리포지토리 사용

Camel 2.6에서 사용 가능

INFO: Camel 2.6에서 JdbcAggregationRepository사용

Camel 2.6에서 JdbcAggregationRepository은 camel-jdbc-aggregator 구성 요소에서 제공됩니다. Camel 2.7 이후부터는 JdbcAggregationRepository 이 camel-sql 구성 요소에 제공됩니다.

JdbcAggregationRepository 은 즉시 집계된 메시지를 유지하는 AggregationRepository 입니다. 이렇게 하면 기본 집계기에서 메모리에서만 AggregationRepository 을 사용하므로 메시지가 느슨하지 않습니다. JdbcAggregationRepository 을 Camel과 함께 사용하면 Aggregator에 대한 지속적인 지원을 제공할 수 있습니다.

Exchange가 성공적으로 처리된 경우에만 확인 메서드가 AggregationRepository 에서 호출될 때 발생하는 complete로 표시됩니다. 즉, 동일한 Exchange가 다시 실패하면 성공할 때까지 계속 재시도됩니다.

옵션 maximumRedeliveries 를 사용하여 지정된 복구 Exchange에 대한 최대 재전송 시도 횟수를 제한할 수 있습니다. 또한 Camel이 maximumRedeliveries 가 발생할 때 Exchange를 보내야 하는 위치를 알 수 있도록 deadLetterUri 옵션을 설정해야 합니다.

camel-sql의 단위 테스트에서 몇 가지 예를 볼 수 있습니다(예: 이 테스트 ).

CREATE TABLE aggregation (
 id varchar(255) NOT NULL,
 exchange blob NOT NULL,
 constraint aggregation_pk PRIMARY KEY (id)
);
CREATE TABLE aggregation_completed (
 id varchar(255) NOT NULL,
 exchange blob NOT NULL,
 constraint aggregation_completed_pk PRIMARY KEY (id)
);