5.18. Timer
5.18.1. camel-timer-kafka-connector ソース設定 リンクのコピーリンクがクリップボードにコピーされました!
コネクターの説明: java.util.Timer を使用して、指定された間隔でメッセージを生成します。
camel-timer-kafka-connector をソースとして使用する場合、以下の Maven 依存関係を使用してコネクターをサポートするようにしてください。
Kafka コネクションでこのソースコネクターを使用するには、以下の connector.class を設定する必要があります。
connector.class=org.apache.camel.kafkaconnector.timer.CamelTimerSourceConnector
connector.class=org.apache.camel.kafkaconnector.timer.CamelTimerSourceConnector
camel-timer ソースコネクターは、以下に示す 16 のオプションをサポートします。
名前 | 説明 | デフォルト | 必要性 | 優先順位 |
---|---|---|---|---|
camel.source.path.timerName | タイマーの名前 | null | true | HIGH |
camel.source.endpoint.bridgeErrorHandler | コンシューマーの Camel ルーティングエラーハンドラーへのブリッジを許可します。よって、コンシューマーが受信メッセージなどの取得を試行している間に発生した例外は、メッセージとして処理され、ルーティングエラーハンドラーによって処理されます。デフォルトでは、コンシューマーは org.apache.camel.spi.ExceptionHandler を使用して例外に対応し、WARN または ERROR レベルでログに記録され、無視されます。 | false | false | MEDIUM |
camel.source.endpoint.delay | 最初のイベントがトリガーされるまでの遅延。 | 1000L | false | MEDIUM |
camel.source.endpoint.fixedRate | イベントは、指定された期間で区切られたほぼ一定の間隔で発生します。 | false | false | MEDIUM |
camel.source.endpoint.includeMetadata | 起動時間、タイマー名、タイマーカウントなどのメタデータを交換に含めるかどうか。この情報はデフォルトで含まれています。 | true | false | MEDIUM |
camel.source.endpoint.period | 0 より大きい場合、周期ごとに定期的なイベントを生成します。 | 1000L | false | MEDIUM |
camel.source.endpoint.repeatCount | 実行の最大数を指定します。したがって、1 に設定すると、タイマーは 1 回だけ起動します。これを 5 に設定した場合、5 回だけ実行されます。0 または負の値を設定すると、無制限に実行されます。 | 0L | false | MEDIUM |
camel.source.endpoint.exceptionHandler | コンシューマーによるカスタム ExceptionHandler の使用を許可します。bridgeErrorHandler オプションが有効な場合は、このオプションは使用されないことに注意してください。デフォルトでは、コンシューマーは例外に対応し、WARN または ERROR レベルでログに記録され、無視されます。 | null | false | MEDIUM |
camel.source.endpoint.exchangePattern | コンシューマーがエクスチェンジを作成する際に交換パターンを設定します。[InOnly]、[InOut]、[InOptionalOut] のいずれか。 | null | false | MEDIUM |
camel.source.endpoint.daemon | タイマーエンドポイントに関連付けられたスレッドがデーモンとして実行されるかどうかを指定します。デフォルト値は true です。 | true | false | MEDIUM |
camel.source.endpoint.pattern | URI 構文を使用して時間オプションを設定するために使用するカスタムの日付パターンを指定できます。 | null | false | MEDIUM |
camel.source.endpoint.synchronous | 同期処理を厳密に使用するかどうかを設定します。 | false | false | MEDIUM |
camel.source.endpoint.time | 最初のイベントが生成される java.util.Date。URI を使用する場合、予想されるパターンは次のとおりです: yyyy-MM-dd HH:mm:ss または yyyy-MM-dd'T'HH:mm:ss。 | null | false | MEDIUM |
camel.source.endpoint.timer | カスタムタイマーを使用するには | null | false | MEDIUM |
camel.component.timer.bridgeErrorHandler | コンシューマーの Camel ルーティングエラーハンドラーへのブリッジを許可します。よって、コンシューマーが受信メッセージなどの取得を試行している間に発生した例外は、メッセージとして処理され、ルーティングエラーハンドラーによって処理されます。デフォルトでは、コンシューマーは org.apache.camel.spi.ExceptionHandler を使用して例外に対応し、WARN または ERROR レベルでログに記録され、無視されます。 | false | false | MEDIUM |
camel.component.timer.autowiredEnabled | 自動ワイヤリングが有効になっているかどうか。これは、コンポーネントで設定される一致するタイプのインスタンスが 1 つあるかどうかを検出するためにレジストリーを検索することで、自動ワイアリングオプションに使用されます (オプションは自動ワイアとマーク付けされる必要があります)。これは、JDBC データソース、JMS 接続ファクトリー、AWS クライアントなどの自動設定に使用できます。 | true | false | MEDIUM |
camel-timer ソースコネクターには、すぐに使用できるコンバータはありません。
camel-timer ソースコネクターには、すぐに使える変換はありません。
camel-timer ソースコネクターには、すぐに使用できる集約ストラテジーはありません。