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

projectId (common)

必須 Google Cloud PubSub プロジェクト ID。

String

destinationName (common)

必須 宛先名。consumer の場合、これはサブスクリプション名になりますが、producer の場合はトピック名になります。

String

authenticate (common)

PubSub サービスと対話する場合は Credentials を使用します (エミュレーターを使用する場合は認証は必要ありません)。

true

boolean

loggerId (common)

親ルートとの一致が必要な場合に使用するロガー ID。

String

serviceAccountKey (common)

PubSub パブリッシャー/サブスクライバーの認証情報として使用できるサービスアカウントキー。デフォルトではクラスパスからロードできますが、classpath:、file:、または http: の接頭辞を付けて、別のシステムからリソースをロードできます。

String

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))

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

false

boolean

exceptionHandler (consumer (advanced))

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

ExceptionHandler

exchangePattern (consumer (advanced))

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

列挙値:

ExchangePattern

lazyStartProducer (producer (advanced))

最初のメッセージでプロデューサーをレイジーに起動すべきかどうか。レイジーに起動することで、起動時に producer が失敗し、それによりルートが失敗する可能性がある状況で、CamelContext およびルートの起動を許可します。レイジーな起動を延期すると、Camel のルーティングエラーハンドラー経由でメッセージのルーティング中に起動の失敗を処理できます。最初のメッセージが処理されるときに、producer の作成および起動に若干時間がかかり、合計処理時間が長くなる可能性があることに注意してください。

false

boolean

messageOrderingEnabled (producer (advanced))

メッセージの順序付けを有効にする必要があります。

false

boolean

pubsubEndpoint (producer (高度))

使用する Pub/Sub エンドポイント。メッセージの順序付けを使用する場合に必要であり、複数のパブリッシャーが使用されている場合でもメッセージが順番に受信されるようにします。

String

シリアライザー (producer (高度))

Autowired producer でのメッセージペイロードのシリアライズに使用するカスタム GooglePubsubSerializer。

GooglePubsubSerializer