From 124294b32fb559d5d6db1f06ffdea0f93399cb37 Mon Sep 17 00:00:00 2001 From: Tianzi Cai Date: Thu, 9 Aug 2018 16:52:40 -0700 Subject: [PATCH] Modified RetrySettings --- .../cloud/examples/pubsub/snippets/PublisherSnippets.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/google-cloud-examples/src/main/java/com/google/cloud/examples/pubsub/snippets/PublisherSnippets.java b/google-cloud-examples/src/main/java/com/google/cloud/examples/pubsub/snippets/PublisherSnippets.java index 0682e8dc4be9..51638dfe353f 100644 --- a/google-cloud-examples/src/main/java/com/google/cloud/examples/pubsub/snippets/PublisherSnippets.java +++ b/google-cloud-examples/src/main/java/com/google/cloud/examples/pubsub/snippets/PublisherSnippets.java @@ -108,11 +108,17 @@ public Publisher getPublisherWithCustomRetrySettings(ProjectTopicName topicName) Duration retryDelay = Duration.ofMillis(100); // default : 1 ms double retryDelayMultiplier = 2.0; // back off for repeated failures Duration maxRetryDelay = Duration.ofSeconds(5); // default : 10 seconds + Duration totalTimeout = Duration.ofSeconds(1); // default: 0 + Duration initialRpcTimeout = Duration.ofSeconds(1); // default: 0 + Duration maxRpcTimeout = Duration.ofSeconds(10); // default: 0 RetrySettings retrySettings = RetrySettings.newBuilder() .setInitialRetryDelay(retryDelay) .setRetryDelayMultiplier(retryDelayMultiplier) .setMaxRetryDelay(maxRetryDelay) + .setTotalTimeout(totalTimeout) + .setInitialRpcTimeout(initialRpcTimeout) + .setMaxRpcTimeout(maxRpcTimeout) .build(); Publisher publisher = Publisher.newBuilder(topicName)