43.3.2. クエリーパラメーター(26 パラメーター):


Expand
Name説明デフォルトType

コマンド (common)

Pute は、ジョブを Beantalk に配置する手段にします。ジョブボディーは Camel メッセージボディーに指定されます。ジョブ ID は beanstalk.jobId メッセージヘッダーで返されます。delete、release、touch、または bury はメッセージヘッダー beantalk.jobId のジョブ ID が予想されます。オペレーションの結果は beanstalk.result メッセージヘッダーキックで返されるため、ジョブの数がメッセージボディーで開始されることを想定し、メッセージヘッダー beantalk.result で実際に起動されたジョブの数を返します。

 

BeanstalkCommand

jobDelay (共通)

ジョブの遅延(秒単位)。

0

int

JobPriority (common)

ジョブの優先度。(0 は最も高い Beantalk プロトコルです)

1000

Long

jobTimeToRun (common)

数秒で実行するジョブ時間(0 の場合、beanstalkd デーモンが自動的に 1 に送出します。beantalk プロトコル を参照してください)。

60

int

awaitJob (consumer)

ジョブが完了するまで待ってから Beantalk からのジョブを認証するかどうか

true

boolean

bridgeErrorHandler (consumer)

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

false

boolean

onFailure (consumer)

処理の失敗時に使用するコマンド。

 

BeanstalkCommand

sendEmptyMessageWhenIdle (consumer)

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

false

boolean

useBlockIO (consumer)

blockIO を使用するかどうか。

true

boolean

exceptionHandler (consumer)

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

 

ExceptionHandler

exchangePattern (consumer)

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

 

ExchangePattern

pollStrategy (consumer)

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

 

PollingConsumerPoll Strategy

同期 (詳細)

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

false

boolean

backoffErrorThreshold (scheduler)

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

 

int

backoffIdleThreshold (scheduler)

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

 

int

backoffMultiplier (scheduler)

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

 

int

遅延 (スケジューラー)

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

500

Long

greedy (scheduler)

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

false

boolean

initialDelay (scheduler)

最初のポーリングが開始されるまでの時間 (ミリ秒単位)。また、60 秒(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 ベースのスケジューラーを使用する場合に追加のプロパティーを設定します。

 

マップ

startScheduler (scheduler)

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

true

boolean

timeUnit (scheduler)

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

ミリ秒

TimeUnit

useFixedDelay (scheduler)

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

true

boolean

プロデューサーの動作は、ジョブの処理方法を示す command パラメーターの影響を受けます。

コンシューマーは、予約後すぐにジョブを削除するか、Camel ルートがジョブを処理するまで待機します。最初のシナリオは「メッセージキュー」のようになりますが、2 つ目は「ジョブキュー」に似ています。この動作は、デフォルトで true と等しい consumer.awaitJob パラメーターにより制御されます(Beanstalkd の性質に従う)。

同期すると、コンシューマーは正常なジョブの完了時に 削除 され、失敗時に bury を呼び出します。URI に consumer.onFailure パラメーターを指定すると、どのコマンドが失敗した場合に実行するコマンドを選択できます。bury、 delete 、または release の値を取ることができます。

JavaBeanstalkClient ライブラリーの同じパラメーターに対応するブール値パラメーター consumer.useBlockIO があります。デフォルトでは true です。

リリース を指定する場合は注意してください。失敗したジョブが同じ場所ですぐに利用可能になり、コンシューマーはこれを再度取得しようとするので注意が必要です。ただし、 jobDelay を リリース し、指定できます。

beanstalk コンシューマーは Scheduled Polling Consumer であり、コンシューマーがポーリングする頻度など、設定可能なオプションがあります。詳細は「コンシューマーのポーリング」を参照してください。

トップに戻る
Red Hat logoGithubredditYoutubeTwitter

詳細情報

試用、購入および販売

コミュニティー

Red Hat ドキュメントについて

Red Hat をお使いのお客様が、信頼できるコンテンツが含まれている製品やサービスを活用することで、イノベーションを行い、目標を達成できるようにします。 最新の更新を見る.

多様性を受け入れるオープンソースの強化

Red Hat では、コード、ドキュメント、Web プロパティーにおける配慮に欠ける用語の置き換えに取り組んでいます。このような変更は、段階的に実施される予定です。詳細情報: Red Hat ブログ.

会社概要

Red Hat は、企業がコアとなるデータセンターからネットワークエッジに至るまで、各種プラットフォームや環境全体で作業を簡素化できるように、強化されたソリューションを提供しています。

Theme

© 2025 Red Hat