Red Hat Training

A Red Hat training course is available for Red Hat Fuse

70.6. 集約リポジトリー

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;

または、CassandraAggregationRepository には NAME 列がなく、別のデータモデルを使用するように拡張できます。

オプションデフォルト説明

表

CAMEL_AGGREGATION

テーブル名

pkColumns

NAME,KEY

プライマリーキー列

exchangeIdColumn

EXCHANGE_ID

エクスチェンジ ID 列

exchangeColumn

EXCHANGE

コンテンツ列の交換

name

 

リポジトリー名（ NAME 列に使用する値）

ttl

 

Exchange time to live

writeConsistencyLevel

 

交換の挿入/削除に使用される整合性レベル： ANY、ONE、TWO、QUORUM、LOCAL_QUORUM…

readConsistencyLevel

 

エクスチェンジの読み取り/確認に使用される整合性レベル： ONE、TWO、QUORUM、LOCAL_QUORUM…