Skip to content

Commit edc7aff

Browse files
Modified RetrySettings (#3549)
1 parent bef4b9d commit edc7aff

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

google-cloud-examples/src/main/java/com/google/cloud/examples/pubsub/snippets/PublisherSnippets.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -108,11 +108,17 @@ public Publisher getPublisherWithCustomRetrySettings(ProjectTopicName topicName)
108108
Duration retryDelay = Duration.ofMillis(100); // default : 1 ms
109109
double retryDelayMultiplier = 2.0; // back off for repeated failures
110110
Duration maxRetryDelay = Duration.ofSeconds(5); // default : 10 seconds
111+
Duration totalTimeout = Duration.ofSeconds(1); // default: 0
112+
Duration initialRpcTimeout = Duration.ofSeconds(1); // default: 0
113+
Duration maxRpcTimeout = Duration.ofSeconds(10); // default: 0
111114

112115
RetrySettings retrySettings = RetrySettings.newBuilder()
113116
.setInitialRetryDelay(retryDelay)
114117
.setRetryDelayMultiplier(retryDelayMultiplier)
115118
.setMaxRetryDelay(maxRetryDelay)
119+
.setTotalTimeout(totalTimeout)
120+
.setInitialRpcTimeout(initialRpcTimeout)
121+
.setMaxRpcTimeout(maxRpcTimeout)
116122
.build();
117123

118124
Publisher publisher = Publisher.newBuilder(topicName)

0 commit comments

Comments
 (0)