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;

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

选项	默认	描述
`table`	`CAMEL_IDEMPOTENT`	表名称
`pkColumns`	`名称`,' 键'	主键列
`name`		Repository name，用于 `NAME` 列的值
`ttl`		实时的关键时间
`writeConsistencyLevel`		用于插入/删除密钥的一致性级别： `ANY`,`ONE`,`TWO`,`QUORUM`,`LOCAL_QUORUM`…
`readConsistencyLevel`		用于读取/检查密钥的一致性级别： `ONE`、`TWO`、`QUORUM`、`LOCAL_QUORUM`…

返回顶部

13.7. 幂等软件仓库

学习

尝试、购买和销售

社区

关于红帽文档

让开源更具包容性

關於紅帽

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links