Googleのpubsubパブリッシャとサブスクライバにタイムアウトを設定するにはどうすればよいですか？

Question

私のJavaコードでは、Google -pubsubを使用しています。タイムアウトの期限が切れるまでのメッセージを待つ - 私は

加入者のためのタイムアウトを設定する方法を

？ （再試行ポリシーを設定するにはどうすればよいですか）

timeout時間のメッセージが送信されます。 （どのように私は、再試行ポリシーを設定することができますか？）

が、私はこの postを見ましたが、Java

ここ

へのjs翻訳するに管理していませんでしたが、私は自分のサブを設定する方法です

final Subscriber subscriber = Subscriber 
      .defaultBuilder(subscriptionName, receiver) 
      .setChannelProvider(channelProvider) 
      .build(); 

とpub

final Publisher publisher = Publisher.defaultBuilder(topicName) 
      .setChannelProvider(channelProvider) 
      .build(); 

Answer 1

最新のCloud Pub/Sub client libraryでは、タイムアウトを設定したり、サブスクライバでポリシーを再試行する必要はありません。これらはあなたのためにフードの下で処理され、MessageReceiverをdefaultBuilderに渡すだけで済みます。メッセージが利用可能になると、receiveMessageに送信されます。再試行不可能な理由で加入が停止した場合、加入者はシャットダウンされます。加入者のaddListenerに電話すると、これらの通知を聞くことができます。

パブリッシャーでは、setRetrySettingsをビルダーで使用できます。特に、RetrySettings.BuilderのsetTotalTimeoutを使用します。パブリッシャは、この合計期限まで再試行可能なエラーでパブリッシュコールを再試行します。