331.2. オプション

kind

必須 System.in や System.out など、使用するストリームの種類。

String

encoding (common)

エンコーディング (文字セット名) を設定して、テキストベースのストリームを使用できます (たとえば、メッセージボディーは String オブジェクトです)。指定しない場合、Camel は JVM のデフォルトの文字セットを使用します。

String

fileName (common)

stream:file URI 形式を使用する場合、このオプションはストリーミング先またはストリーミング元のファイル名を指定します。

String

url (common)

stream:url URI 形式を使用する場合、このオプションは、ストリーミング先/ストリーミング元の URL を指定します。入出力ストリームは、JDK URLConnection 機能を使用して開かれます。

String

bridgeErrorHandler (consumer)

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

false

boolean

fileWatcher (consumer)

JVM ファイルウォッチャーを使用してファイル変更イベントをリッスンし、tail --retry のように、上書きされる可能性のあるファイルの再ロードをサポートする場合。

false

boolean

groupLines (consumer)

コンシューマーで X 行をグループ化します。たとえば、10 行をグループ化して、行ごとに 1 つの Exchange ではなく、10 行の Exchange のみを出力する場合。

int

groupStrategy (consumer)

カスタム GroupStrategy を使用して、行をグループ化する方法を制御できます。

GroupStrategy

initialPromptDelay (consumer)

メッセージプロンプトを表示するまでのミリ秒単位の初期遅延。この遅延は 1 回だけ発生します。システムの起動時に使用して、システム出力への他のロギングが行われている間にメッセージプロンプトが書き込まれるのを回避できます。

2000

long

promptDelay (consumer)

メッセージプロンプトを表示するまでのオプションの遅延 (ミリ秒単位)。

long

promptMessage (consumer)

stream:in; からの読み取り時に使用するメッセージプロンプト。たとえば、コマンドを入力するように設定できます。

String

retry (consumer)

ストリームが上書きされた場合、ストリームを開くことを再試行します。これは、tail --retry に似ています。ファイルから読み取る場合は、fileWatcher オプションも有効にして、信頼できるように動作させる必要があります。

false

boolean

scanStream (consumer)

unix tail コマンドなどのストリームを連続して読み取るために使用します。

false

boolean

scanStreamDelay (consumer)

scanStream 使用時の読み取り試行間のミリ秒単位の遅延。

long

exceptionHandler (consumer)

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

ExceptionHandler

exchangePattern (consumer)

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

ExchangePattern

autoCloseCount (producer)

プロデューサー側でストリームを閉じる前に処理するメッセージの数。デフォルトではストリームを閉じない (プロデューサーが停止している場合のみ)。さらにメッセージが送信されると、別の autoCloseCount バッチのためにストリームが再度開かれます。

int

closeOnDone (producer)

このオプションは、Splitter および同じファイルへのストリーミングと組み合わせて使用されます。そのアイデアは、パフォーマンスを向上させるために、ストリームを開いたままにし、スプリッターが完了したときにのみ閉じることです。これには、2 つ以上のファイルではなく、同じファイルにのみストリーミングする必要があることに注意してください。

false

boolean

delay (producer)

ストリームを生成する前のミリ秒単位の初期遅延。

long

connectTimeout (advanced)

この URLConnection によって参照されるリソースへの通信リンクを開くときに使用される、指定されたタイムアウト値をミリ秒単位で設定します。接続が確立される前にタイムアウトになると、java.net.SocketTimeoutException が発生します。ゼロのタイムアウトは、無限のタイムアウトとして解釈されます。

int

httpHeaders (advanced)

HTTP URL を使用するときにリクエストで使用するオプションの http ヘッダー。

Map

readTimeout (advanced)

読み取りタイムアウトをミリ秒単位で指定されたタイムアウトに設定します。ゼロ以外の値は、リソースへの接続が確立されたときに入力ストリームから読み取るときのタイムアウトを指定します。読み取り可能なデータが存在する前にタイムアウトになると、java.net.SocketTimeoutException が発生します。ゼロのタイムアウトは、無限のタイムアウトとして解釈されます。

int

synchronous (advanced)

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

false

boolean