72.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;
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 and Set とも呼ばれます) を使用し、Cassandra 2.0.7+ が必要です。
または、CassandraIdempotentRepository
には NAME
列がなく、別のデータモデルを使用するように拡張できます。
オプション | デフォルト | 説明 |
---|---|---|
|
| テーブル名 |
|
| 主キー列 |
|
リポジトリー名、 | |
| 重要な生存期間 | |
|
キーの挿入/削除に使用される一貫性レベル: | |
|
キーの読み取り/チェックに使用される一貫性レベル: |