120.15. JDBC ベースのべき等リポジトリーの使用

createTableIfNotExists

true

テーブルが存在しない場合、Camel がテーブルを作成しようとするかどうかを定義します。

tableName

CAMEL_MESSAGEPROCESSED

デフォルト名の代わりにカスタムテーブル名を使用するには: CAMEL_MESSAGEPROCESSED。

tableExistsString

SELECT 1 FROM CAMEL_MESSAGEPROCESSED WHERE 1 = 0

このクエリーは、テーブルがすでに存在するかどうかを確認するために使用されます。テーブルが存在しないことを示すには、例外を出力する必要があります。

createString

CREATE TABLE CAMEL_MESSAGEPROCESSED (processorName VARCHAR(255), messageId VARCHAR(100), createdAt TIMESTAMP)

テーブルの作成に使用されるステートメント。

queryString

SELECT COUNT(*) FROM CAMEL_MESSAGEPROCESSED WHERE processorName = ?AND messageId = ?

メッセージがリポジトリーにすでに存在するかどうかを判断するために使用されるクエリー (結果は 0 に等しくない)。2 つのパラメーターを取ります。この最初のものはプロセッサー名 (String) で、2 つ目はメッセージ ID (String) です。

insertString

INSERT INTO CAMEL_MESSAGEPROCESSED (processorName, messageId, createdAt) VALUES (?, ?, ?)

エントリーをテーブルに追加するために使用されるステートメント。3 つのパラメーターを取ります。1 つ目はプロセッサー名 (String)、2 つ目はメッセージ ID (String)、3 つ目はこのエントリーがリポジトリーに追加されたときのタイムスタンプ (java.sql.Timestamp) です。

deleteString

DELETE FROM CAMEL_MESSAGEPROCESSED WHERE processorName = ?AND messageId = ?

データベースからエントリーを削除するために使用されるステートメント。2 つのパラメーターを取ります。この最初のものはプロセッサー名 (String) で、2 つ目はメッセージ ID (String) です。

lockMaxAgeMillis

これは、ロックが孤立したと見なされるまでの期間を指します。つまり、currentTimestamp - createdAt >= lockMaxAgeMillis の場合、ロックは孤立しています。

lockKeepAliveIntervalMillis

createdAt Timestamp 列に対してキープアライブ更新が行われる頻度。