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 列がなく、別のデータモデルを使用するように拡張できます。
| オプション | デフォルト | 説明 |
|---|---|---|
|
|
| テーブル名 |
|
|
| プライマリーキー列 |
|
|
| エクスチェンジ ID 列 |
|
|
| コンテンツ列の交換 |
|
|
リポジトリー名( | |
|
| Exchange time to live | |
|
|
交換の挿入/削除に使用される整合性レベル: | |
|
|
エクスチェンジの読み取り/確認に使用される整合性レベル: |