15.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
列,并可扩展为使用不同的数据模型。
选项 | Default(默认) | 描述 |
---|---|---|
|
| 表名称 |
|
| 主密钥列 |
|
| Exchange Id 列 |
|
| 交换内容列 |
|
软件仓库名称,用于 | |
| 交换时间 | |
|
用于插入/删除交换的一致性级别: | |
|
用于读取/检查交换的一致性级别: |