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

Camel 2.6에서 사용 가능

정보: Camel 2.6에서 JdbcAggregationRepository 사용

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

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

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

maximumRedeliveries 옵션을 사용하면 복구된 교환에 대한 최대 재전송 시도 횟수를 제한할 수 있습니다. 또한 Camel에서 maximumRedeliveries 에 도달했을 때 교환을 보낼 위치를 알 수 있도록 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)
);