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;

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

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

返回顶部

72.6. 幂等存储库

学习

尝试、购买和销售

社区

关于红帽文档

让开源更具包容性

關於紅帽

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links