73.7. 聚合存储库
NamedCassandraAggregationRepository
在 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;
或者,Cas1AggregationRepository
没有 NAME
列,可以扩展为使用不同的数据模型。
选项 | 默认 | 描述 |
---|---|---|
|
| 表名称 |
|
| 主键列 |
|
| exchange Id 列 |
|
| Exchange content 列 |
|
仓库名称,用于 | |
| 交换生存时间 | |
|
用于插入/删除交换的一致性级别:NY、 | |
|
用于读取/检查交换的一致性级别: |