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