14.8. 聚合存储库

NamedCassandraAggregationRepository 通过在 Cassandra 表中关联键存储交换，如下所示：

CAMEL_AGGREGATION.cql

CREATE TABLE CAMEL_AGGREGATION (
  NAME varchar,        -- Repository name
  KEY varchar,         -- Correlation id
  EXCHANGE_ID varchar, -- Exchange id
  EXCHANGE blob,       -- Serialized exchange
  PRIMARY KEY (NAME, KEY)
) WITH compaction = {'class':'LeveledCompactionStrategy'}
  AND gc_grace_seconds = 86400;

CREATE TABLE CAMEL_AGGREGATION (
  NAME varchar,        -- Repository name
  KEY varchar,         -- Correlation id
  EXCHANGE_ID varchar, -- Exchange id
  EXCHANGE blob,       -- Serialized exchange
  PRIMARY KEY (NAME, KEY)
) WITH compaction = {'class':'LeveledCompactionStrategy'}
  AND gc_grace_seconds = 86400;

Copy to Clipboard

Toggle word wrap

或者，CassandraAggregationRepository 没有 NAME 列，并可扩展为使用不同的数据模型。

Expand

选项	默认值	描述
`表`	`CAMEL_AGGREGATION`	表名称
`pkColumns`	`名称`,`KEY`	主键列
`exchangeIdColumn`	`EXCHANGE_ID`	Exchange Id 列
`exchangeColumn`	`EXCHANGE`	Exchange content 列
`name`		Repository name，用于 `NAME` 列的值
`ttl`		交换生存时间
`writeConsistencyLevel`		用于插入/删除交换的一致性级别： `ANY`,`ONE`,`TWO`,`QUORUM`,`LOCAL_QUORUM`…
`readConsistencyLevel`		用于读取/检查交换的一致性级别： `ONE`、`TWO`、`QUORUM`、`LOCAL_QUORUM`…

返回顶部

14.8. 聚合存储库

学习

尝试、购买和销售

社区

关于红帽文档

让开源更具包容性

關於紅帽

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links