comment définir le délai d'expiration pour google pubsub éditeur et abonné?

Question

Dans mon code java, j'utilise Google -pubsub.

comment puis-je définir un délai pour

abonné - attendre jusqu'à ce que les messages délai d'expiration? (comment puis-je définir une politique de réessai?)

éditeur - attendre jusqu'à ce que le message est envoyé pour timeout temps. (comment puis-je définir une stratégie de nouvelle tentative?)

J'ai vu ce post mais n'a pas réussi à traduire le message js java

Voici comment je tournerai ma sous

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

et pub

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

Answer 1

Avec la dernière Cloud Pub/Sub client library, vous n'avez pas besoin de définir les délais d'attente ou une nouvelle tentative des politiques dans l'abonné. Ceux-ci sont gérés sous le capot pour vous et vous avez juste besoin de passer votre MessageReceiver en defaultBuilder. Lorsque les messages sont disponibles, ils sont envoyés au receiveMessage. Si votre abonnement s'arrête pour une raison non réessayable, l'abonné sera fermé. Vous pouvez écouter ces notifications en appelant le addListener sur votre Abonné.

Sur l'éditeur, vous pouvez utiliser setRetrySettings dans le générateur. En particulier, vous voudriez setTotalTimeout sur RetrySettings.Builder. L'éditeur réessayera de publier les appels sur les erreurs réessayables jusqu'à ce délai total.