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