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

Camel 2.6에서 사용 가능

INFO: Camel 2.6에서 JdbcAgregationRepository 사용

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

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

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

옵션 maximumRedeliveries 를 사용하여 지정된 복구된 교환에 대한 최대 복구 시도 횟수를 제한할 수 있습니다. 또한 Camel은 최대Redeliveries 에 도달했을 때 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)
);

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)
);