70.5. べき等リポジトリー
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;
このリポジトリー実装は、軽量トランザクション(Compare および Set とも呼ばれます)を使用し、Cassandra 2.0.7 以降が必要になります。
または、CassandraIdempotentRepository には NAME 列がなく、別のデータモデルを使用するように拡張できます。
| オプション | デフォルト | 説明 |
|---|---|---|
|
|
| テーブル名 |
|
|
| プライマリーキー列 |
|
|
リポジトリー名( | |
|
| キーの有効期間 | |
|
|
キーの挿入/削除に使用される整合性レベル: | |
|
|
キーの読み取り/確認に使用される整合性レベル: |