73.7. 聚合存储库
NamedCassandraAggregationRepository
根据 correlation 键在 Cassandra 表中存储交换,如下所示:
CAMEL_AGGREGATION.cql
CREATE TABLE CAMEL_AGGREGATION ( NAME varchar, -- Repository name KEY varchar, -- Correlation id EXCHANGE_ID varchar, -- Exchange id EXCHANGE blob, -- Serialized exchange PRIMARY KEY (NAME, KEY) ) WITH compaction = {'class':'LeveledCompactionStrategy'} AND gc_grace_seconds = 86400;
或者,CassandraAggregationRepository
没有 NAME
列,并可扩展为使用不同的数据模型。
选项 | 默认 | 描述 |
---|---|---|
|
| 表名称 |
|
| 主要键列 |
|
| Exchange Id 列 |
|
| Exchange content 列 |
|
存储库名称,用于 | |
| 交换生存时间 | |
|
用于插入/删除交换的一致性级别:任意、 | |
|
用于读取/检查交换的一致性级别: |