68.2. オプション

protocol

必須 使用するプロトコル

String

hostname

必須 使用するホスト名

String

port

使用するポート番号

8091

int

bucket (common)

使用するバケット

String

key (common)

使用する鍵

String

bridgeErrorHandler (consumer)

コンシューマーの Camel ルーティングエラーハンドラーへのブリッジを許可します。よって、コンシューマーが受信メッセージなどの取得を試行している間に発生した例外は、メッセージとして処理され、ルーティングエラーハンドラーによって処理されます。デフォルトでは、コンシューマーは org.apache.camel.spi.ExceptionHandler を使用して例外に対応し、WARN または ERROR レベルでログに記録され、無視されます。

false

boolean

consumerProcessedStrategy (consumer)

使用するコンシューマー処理済み戦略を定義する

none

String

descending (consumer)

この操作が降順かどうかを定義します

false

boolean

designDocumentName (consumer)

使用する設計ドキュメント名

beer

String

limit (consumer)

使用する出力制限

-1

int

rangeEndKey (consumer)

終了キーの範囲を定義する

String

rangeStartKey (consumer)

開始キーの範囲を定義する

String

sendEmptyMessageWhenIdle (consumer)

ポーリングコンシューマーがファイルをポーリングしなかった場合、このオプションを有効にして、代わりに空のメッセージ (ボディーなし) を送信できます。

false

boolean

skip (consumer)

使用するスキップを定義する

-1

int

viewName (consumer)

使用するビュー名

brewery_beers

String

exceptionHandler (consumer)

コンシューマーによるカスタム ExceptionHandler の使用を許可します。bridgeErrorHandler オプションが有効な場合は、このオプションは使用されないことに注意してください。デフォルトでは、コンシューマーは例外に対応し、WARN または ERROR レベルでログに記録され、無視されます。

ExceptionHandler

exchangePattern (consumer)

コンシューマーがエクスチェンジを作成する際に交換パターンを設定します。

ExchangePattern

pollStrategy (consumer)

プラグ可能な org.apache.camel.PollingConsumerPollingStrategy を使用すると、エクスチェンジが作成され、Camel でルーティングされる前に、通常はポーリング操作中に発生するエラー処理を制御するカスタム実装が提供できます。

PollingConsumerPoll Strategy

autoStartIdForInserts (producer)

挿入操作を行っているときに自動開始 ID が必要かどうかを定義します

false

boolean

operation (producer)

やるべき操作

CCB_PUT

String

persistTo (producer)

データを永続化する場所

0

int

producerRetryAttempts (producer)

再試行回数を定義する

2

int

producerRetryPause (producer)

異なる試行間の再試行の一時停止を定義する

5000

int

replicaTo (producer)

データをレプリケートする場所

0

int

startingIdForInsertsFrom (producer)

挿入操作を行っている開始 ID を定義します

long

additionalHosts (advanced)

追加のホスト

String

maxReconnectDelay (advanced)

再接続中の最大遅延を定義する

30000

long

obsPollInterval (advanced)

監視ポーリング間隔を定義する

400

long

obsTimeout (advanced)

監視タイムアウトを定義する

-1

long

opQueueMaxBlockTime (advanced)

操作がキューにブロックされている最大時間を定義する

10000

long

opTimeOut (advanced)

操作タイムアウトを定義する

2500

long

readBufferSize (advanced)

バッファーサイズを定義する

16384

int

shouldOptimize (advanced)

可能な場合は最適化を使用するかどうかを定義します

false

boolean

synchronous (advanced)

同期処理を厳密に使用するか、Camel が非同期処理を使用できるかどうかを設定します (サポートされている場合)。

false

boolean

timeoutExceptionThreshold (advanced)

タイムアウト例外を出力するためのしきい値を定義します

998

int

backoffErrorThreshold (scheduler)

backoffMultipler が開始する前に発生する必要がある後続のエラーポーリング (エラーによって失敗した) の数。

int

backoffIdleThreshold (scheduler)

backoffMultipler が開始する前に発生する必要がある後続のアイドルポーリングの数。

int

backoffMultiplier (scheduler)

後続のアイドル状態/エラーが連続して発生した場合に、スケジュールされたポーリングコンシューマーのバックオフを許可します。乗数は、実際に次の試行が行われる前にスキップされるポーリングの数です。このオプションが使用されている場合は、backoffIdleThreshold や backoffErrorThreshold も設定する必要があります。

int

delay (scheduler)

次のポーリングまでの時間 (ミリ秒単位)。60s (60 秒)、5m30s (5 分 30 秒)、1h (1 時間) などの単位を使用して時間値を指定することもできます。

500

long

greedy (scheduler)

greedy が有効で、以前の実行が 1 つ以上のメッセージをポーリングした場合、ScheduledPollConsumer は即座に再度実行されます。

false

boolean

initialDelay (scheduler)

最初のポーリングが開始されるまでの時間 (ミリ秒単位)。60s (60 秒)、5m30s (5 分 30 秒)、1h (1 時間) などの単位を使用して時間値を指定することもできます。

1000

long

runLoggingLevel (scheduler)

コンシューマーはポーリング時に開始/完了のログ行を記録します。このオプションを使用すると、ログレベルを設定できます。

TRACE

LoggingLevel

scheduledExecutorService (scheduler)

コンシューマーに使用するカスタム/共有スレッドプールを設定できます。デフォルトでは、各コンシューマーに独自の単一スレッドのスレッドプールがあります。

ScheduledExecutor Service

scheduler (scheduler)

camel-spring または camel-quartz2 コンポーネントから cron スケジューラーを使用します。

none

ScheduledPollConsumer Scheduler

schedulerProperties (scheduler)

カスタムスケジューラーまたは Quartz2 や Spring ベースのスケジューラーを使用する場合に、追加のプロパティーを設定します。

Map

startScheduler (scheduler)

スケジューラーを自動起動するかどうか。

true

boolean

timeUnit (scheduler)

initialDelay および delay オプションの時間単位。

MILLISECONDS

TimeUnit

useFixedDelay (scheduler)

固定遅延または固定レートを使用するかどうかを制御します。詳細は、JDK の ScheduledExecutorService を参照してください。

true

boolean

password (security)

使用するパスワード

String

username (security)

使用するユーザー名

文字列