326.14. 使用基于 JDBC 的聚合存储库

从 Camel 2.6 开始提供

INFO: 在 Camel 2.6 中使用 JdbcAggregationRepository

在 Camel 2.6 中，JdbcAggregationRepository 在 camel-jdbc-aggregator 组件中提供。从 Camel 2.7 开始，J dbcAggregationRepository 在 camel-sql 组件中提供。

JdbcAggregationRepository 是一个 AggregationRepository，它实时保留聚合的消息。这样可确保您不会松散消息，因为默认聚合器将使用仅在内存中的 AggregationRepository。JdbcAggregationRepository 允许 Camel 与 Camel 共同提供对聚合器的持久支持。

只有在成功处理交换时，才会将其标记为 complete，只有在 AggregationRepository 上调用 confirm 方法时才会发生这种情况。这意味着，如果同一交换再次失败，它将被重试，直到成功为止。

您可以使用选项 maximumRedeliveries 来限制给定恢复的交换的最大重新发送尝试次数。您还必须设置 deadLetterUri 选项，以便 Camel 知道在 max Redeliveries 正在命中时要发送交换的位置。

您可以在 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)
);