13.8. 聚合仓库
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;
另外,CassandraAggregationRepository
没有 NAME
列,并可扩展为使用其他数据模型。
选项 | 默认 | 描述 |
---|---|---|
|
| 表名称 |
|
| 主键列 |
|
| Exchange Id 列 |
|
| Exchange content 列 |
|
存储库名称,值用于 | |
| 交换时间到实时 | |
|
用于插入/删除交换的一致性级别: | |
|
用于读取/检查交换的一致性级别: |