13.7. 幂等仓库
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
列,并可扩展为使用其他数据模型。
选项 | 默认 | 描述 |
---|---|---|
|
| 表名称 |
|
| 主键列 |
|
存储库名称,值用于 | |
| 生存时间 | |
|
用于插入/删除密钥的一致性级别: | |
|
用于读取/检查密钥的一致性级别: |