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。發佈者將重試發佈可調試錯誤的截止日期。

相關問題