Google pubsubフロー制御

Question

私は、自分のペースでGoogleのpubsubサブスクリプションを使用するサービスを実装しようとしています。それで、メッセージを消費する必要があるときに細かい制御が必要なことを意味します。メッセージのバッチを取得し、しばらく停止し、Xメッセージ以上を取得しないようにしてください...

Googleクライアントライブラリを使用していますMessageReceiverが独自のスレッドで実行されているので、それを行う方法であり、何が起こったのかについては何も制御していません。

基本的に、同期的な方法でメッセージを消費することができれば、私の問題は解決します。

googleクライアントライブラリを同期して使用する方法をご存知ですか？それとも、私が見逃したAPIに別の方法がありますか？

Answer 1

サブスクライバの作成時にsetFlowControlSettingsを試してみるとよいでしょう。特に、setMaxOutstandingElementCountまたはsetMaxOutstandingRequestBytesを使用して、MessageReceiverに送信されるメッセージを制限することができます。十分な未処理のメッセージ、つまりAck()またはNack()を呼び出していないメッセージがある場合、これらの制限を超えると、メッセージが受信または停止されるまでMessageReceiverは呼び出されません。