0

在我的java代码中,我使用Google -pubsub。如何将超时设置为Google Pubsub发布者和订阅者?

我怎样才能设置

用户超时 - 等待消息,直到超时? (我如何设置重试策略?)

发布者 - 等到邮件发送时间为timeout时。 (如何设置一个重试策略?)

我看到这个post但没能翻译JS后去渣

这是我如何设置我的子

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

和酒馆

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

回答

0

随着最新Cloud Pub/Sub client library,你并不需要设置超时或重试订购者的政策。这些都是在你面前处理的,你只需要将你的MessageReceiver转换为defaultBuilder即可。当消息可用时,它们将被发送到receiveMessage。如果您的订阅因任何不可重试原因而停止,则订阅者将被关闭。您可以通过在您的订户上致电addListener来收听这些通知。

在发布服务器上,您可以在Builder中使用setRetrySettings。特别是,你想在RetrySettings.Builder上使用setTotalTimeout。发布者将重试发布可调试错误的截止日期。

相关问题