Skip to content
This repository was archived by the owner on Jan 19, 2022. It is now read-only.

Conversation

elefeint
Copy link
Contributor

This is a mix of two things right now:

  1. implementation of error propagation, with a property in the sample that needs to move into documentation.
  2. reproducing a blocking issue in client library, in which failures in gRPC DNS resolution are not propagated to the returned Future.

public class TempClientLibraryTest {

@Test
public void failedPublishCallsListener() throws IOException, InterruptedException {
Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

This test fails; the future error callback is never invoked.

Comment on lines +60 to +65
RetrySettings.newBuilder()
.setMaxAttempts(3)
.setTotalTimeout(org.threeten.bp.Duration.ofSeconds(10))
.setInitialRpcTimeout(org.threeten.bp.Duration.ofSeconds(10))
.setMaxRpcTimeout(org.threeten.bp.Duration.ofSeconds(20)) // TODO: bad message; try 9; longer not shorter
.build())
Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

This is the minimal set of retry settings that work.

Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.

Labels

None yet

Development

Successfully merging this pull request may close these issues.

1 participant