14.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;

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;

Copy to Clipboard

Toggle word wrap

此存储库实施使用轻量级事务（也称为 Compare 和 Set），并且需要 Cassandra 2.0.7+。

此外，CassandraIdempotentRepository 没有 NAME 列，并可扩展为使用其他数据模型。

Expand

Option	默认值	Description
`table`	`CAMEL_IDEMPOTENT`	表名称
`pkColumns`	`名称`，密钥'	主键列
`name`		存储库名称，值用于 `NAME` 列
`ttl`		生存时间
`writeConsistencyLevel`		用于插入/删除密钥的一致性级别： `ANY`、`ONE`、`TWO`、`QUORUM`、`LOCAL_QUORUM`…
`readConsistencyLevel`		用于读取/检查密钥的一致性级别： `ONE`、`TWO`、`QUORUM`、`LOCAL_QUORUM`…

返回顶部

14.7. 幂等仓库

学习

尝试、购买和销售

社区

关于红帽文档

让开源更具包容性

關於紅帽

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links