72.6. 幂等仓库
NamedCassandraIdempotentRepository 在 Cassandra 表中存储消息键,如下所示:
CAMEL_IDEMPOTENT.cql
CREATE TABLE CAMEL_IDEMPOTENT (
NAME varchar, -- Repository name
KEY varchar, -- Message key
PRIMARY KEY (NAME, KEY)
) WITH compaction = {'class':'LeveledCompactionStrategy'}
AND gc_grace_seconds = 86400;此存储库实施使用轻量级事务(也称为 Compare 和 Set),并且需要 Cassandra 2.0.7+。
此外,CassandraIdempotentRepository 没有 NAME 列,并可扩展为使用其他数据模型。
| 选项 | 默认值 | 描述 |
|---|---|---|
|
|
| 表名称 |
|
|
| 主键列 |
|
|
存储库名称,值用于 | |
|
| 生存时间 | |
|
|
用于插入/删除密钥的一致性级别: | |
|
|
用于读取/检查密钥的一致性级别: |