355.2. エンドポイントオプション

streamingType

必須 使用するストリーミングタイプ。

StreamingType

bridgeErrorHandler (consumer)

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

false

boolean

sendEmptyMessageWhenIdle (consumer)

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

false

boolean

type (consumer)

使用するエンドポイントタイプ。ストリーミングのみがイベントタイプをサポートします。

ポーリング

EndpointType

distanceMetric (consumer)

非ストリーム地理検索で使用され、設定されたメトリックを使用して半径で検索します。単位は、マイルを表す mi またはキロメートルを表す km のいずれかです。longitude、latitude、radius、および distanceMetric のオプションをすべて設定する必要があります。

km

String

exceptionHandler (consumer)

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

ExceptionHandler

exchangePattern (consumer)

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

ExchangePattern

extendedMode (consumer)

Twitter から全文を有効にするために使用されます (例: 140 文字を超えるツイートを受信する)。

true

boolean

latitude (consumer)

非ストリーム地理検索で緯度で検索するために使用されます。longitude、latitude、radius、および distanceMetric のオプションをすべて設定する必要があります。

double

locations (consumer)

緯度/経度のペアによって作成される境界ボックス。ストリーミング/フィルターに使用できます。ペアは緯度、経度として定義されます。また、複数のペアーはセミコロンで区切ることができます。

String

longitude (consumer)

非ストリーム地理検索で経度で検索するために使用されます。longitude、latitude、radius、および distanceMetric のオプションをすべて設定する必要があります。

double

pollStrategy (consumer)

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

PollingConsumerPoll Strategy

radius (consumer)

非ストリーム地理検索で半径で検索するために使用されます。longitude、latitude、radius、および distanceMetric のオプションをすべて設定する必要があります。

double

twitterStream (consumer)

TwitterStream のカスタムインスタンスを使用する場合。

TwitterStream

synchronous (advanced)

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

false

boolean

count (filter)

ページあたりの結果数を制限します。

5

Integer

filterOld (filter)

以前にポーリングされた古いツイートを除外します。この状態はメモリーにのみ保存され、最後のツイート ID に基づいています。

true

boolean

keywords (filter)

ストリーミングフィルターに使用できます。複数の値はコンマで区切ることができます。

String

lang (filter)

検索に使用される言語文字列 ISO_639-1

String

numberOfPages (filter)

camel-twitter が消費する結果のページ数。

1

Integer

sinceId (filter)

ツイートをプルするために使用される最後のツイート ID。長時間実行後に camel ルートを再開するときに役立ちます。

1

long

userIds (filter)

ストリーミング/フィルターのユーザー ID でフィルター処理します。複数の値はコンマで区切ることができます。

String

backoffErrorThreshold (scheduler)

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

int

backoffIdleThreshold (scheduler)

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

int

backoffMultiplier (scheduler)

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

int

delay (scheduler)

次のポーリングまでの時間 (ミリ秒単位)。

30000

long

greedy (scheduler)

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

false

boolean

initialDelay (scheduler)

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

1000

long

runLoggingLevel (scheduler)

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

TRACE

LoggingLevel

scheduledExecutorService (scheduler)

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

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

sortById (sort)

ID で並べ替えます。古いものが最初に、新しいものが最後になります。

true

boolean

httpProxyHost (proxy)

camel-twitter に使用できる http プロキシーホスト。代わりに TwitterComponent レベルで設定することもできます。

String

httpProxyPassword (proxy)

camel-twitter に使用できる http プロキシーパスワード。代わりに TwitterComponent レベルで設定することもできます。

String

httpProxyPort (proxy)

camel-twitter に使用できる http プロキシーポート。代わりに TwitterComponent レベルで設定することもできます。

Integer

httpProxyUser (proxy)

camel-twitter に使用できる http プロキシーユーザー。代わりに TwitterComponent レベルで設定することもできます。

String

accessToken (security)

アクセストークン。代わりに TwitterComponent レベルで設定することもできます。

String

accessTokenSecret (security)

アクセスシークレット。代わりに TwitterComponent レベルで設定することもできます。

String

consumerKey (security)

コンシューマーキー。代わりに TwitterComponent レベルで設定することもできます。

String

consumerSecret (security)

コンシューマーシークレット。代わりに TwitterComponent レベルで設定することもできます。

String