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