27.4. エンドポイントオプション
Google Pubsub エンドポイントは、URI 構文を使用して設定されます。
google-pubsub:projectId:destinationName
google-pubsub:projectId:destinationName
パスおよびクエリーパラメーターを使用します。
27.4.1. パスパラメーター (2 パラメーター) リンクのコピーリンクがクリップボードにコピーされました!
名前 | 説明 | デフォルト | タイプ |
---|---|---|---|
projectId (common) | 必須 Google Cloud PubSub プロジェクト ID。 | 文字列 | |
destinationName (common) | 必須 宛先名。consumer の場合、これはサブスクリプション名になりますが、producer の場合はトピック名になります。 | 文字列 |
27.4.2. クエリーパラメーター (15 パラメーター) リンクのコピーリンクがクリップボードにコピーされました!
名前 | 説明 | デフォルト | タイプ |
---|---|---|---|
authenticate (共通) | PubSub サービスと対話する場合は Credentials を使用します (エミュレーターを使用する場合は認証は必要ありません)。 | true | boolean |
loggerId (Common) | 親ルートとの一致が必要な場合に使用するロガー ID。 | 文字列 | |
serviceAccountKey (common) | PubSub パブリッシャー/サブスクライバーの認証情報として使用できるサービスアカウントキー。デフォルトではクラスパスからロードできますが、classpath:、file:、または http: の接頭辞を付けて、別のシステムからリソースをロードできます。 | 文字列 | |
ackMode (consumer) | AUTO = エクスチェンジは完了時に確認/拒否されます。NONE = ダウンストリームプロセスは明示的に ack/nack する必要があります。 列挙値:
| AUTO | AckMode |
concurrentConsumers (consumer) | サブスクリプションから消費する並列ストリームの数。 | 1 | Integer |
maxAckExtensionPeriod (consumer) | メッセージ確認応答期限が延長される最大期間を設定します。秒単位の値。 | 3600 | int |
maxMessagesPerPoll (consumer) | 1 回の API 呼び出しでサーバーから受信するメッセージの最大数。 | 1 | Integer |
synchronousPull (consumer) | メッセージのバッチを同期的にプルします。 | false | boolean |
bridgeErrorHandler (consumer (advanced)) | consumer の Camel ルーティングエラーハンドラーへのブリッジを許可します。よって、consumer が受信メッセージなどの取得を試行している間に発生した例外は、メッセージとして処理され、ルーティングエラーハンドラーによって処理されます。デフォルトでは、consumer は org.apache.camel.spi.ExceptionHandler を使用して例外に対応し、WARN または ERROR レベルでログに記録され、無視されます。 | false | boolean |
exceptionHandler (consumer (上級)) | consumer によるカスタム ExceptionHandler の使用を許可します。bridgeErrorHandler オプションが有効な場合は、このオプションは使用されないことに注意してください。デフォルトでは、consumer は例外に対応し、WARN または ERROR レベルでログに記録され、無視されます。 | ExceptionHandler | |
exchangePattern (consumer (上級)) | consumer がエクスチェンジを作成する際に交換パターンを設定します。 列挙値:
| ExchangePattern | |
lazyStartProducer (producer (advanced)) | 最初のメッセージで producer をレイジーに起動すべきかどうか。レイジーに起動することで、起動時に producer が失敗し、それによりルートが失敗する可能性がある状況で、CamelContext およびルートの起動を許可します。レイジーな起動を延期すると、Camel のルーティングエラーハンドラー経由でメッセージのルーティング中に起動の失敗を処理できます。最初のメッセージが処理されるときに、producer の作成および起動に若干時間がかかり、合計処理時間が長くなる可能性があることに注意してください。 | false | boolean |
messageOrderingEnabled (producer (advanced)) | メッセージの順序付けを有効にする必要があります。 | false | boolean |
pubsubEndpoint (producer (高度)) | 使用する Pub/Sub エンドポイント。メッセージの順序付けを使用する場合に必要であり、複数のパブリッシャーが使用されている場合でもメッセージが順番に受信されるようにします。 | 文字列 | |
シリアライザー (producer (高度)) | Autowired producer でのメッセージペイロードのシリアライズに使用するカスタム GooglePubsubSerializer。 | GooglePubsubSerializer |