Uh oh!
There was an error while loading. Please reload this page.
pubsub: make Publisher use GAPIC client - #3008
Conversation
| publisher.shutdown(); | ||
| } | ||
| public void testPublishFailureRetries_exceededsRetryDuration() throws Exception { |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
Uh oh!
There was an error while loading. Please reload this page.
| /** Returns the object with the settings used for calls to publish. */ | ||
| /* package-private */ BatchingCallSettings<PublishRequest, PublishResponse> publishSettings() { | ||
| /* package-private */ UnaryCallSettings<PublishRequest, PublishResponse> publishSettings() { |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
Uh oh!
There was an error while loading. Please reload this page.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
Uh oh!
There was an error while loading. Please reload this page.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
Uh oh!
There was an error while loading. Please reload this page.
garrettjonesgoogle
commented
Mar 7, 2018
@hzyi-google could you do the first pass? |
| .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("non_idempotent")) | ||
| .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default")); | ||
| // builder |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
Uh oh!
There was an error while loading. Please reload this page.
| BatchingCallSettings.newBuilder(PUBLISH_BATCHING_DESC) | ||
| .setBatchingSettings(BatchingSettings.newBuilder().build()); | ||
| publishSettings = UnaryCallSettings.newUnaryCallSettingsBuilder(); | ||
| // publishSettings = |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
Uh oh!
There was an error while loading. Please reload this page.
pongad
commented
Mar 8, 2018
@hzyi-google PTAL |
yihanzhen
commented
Mar 8, 2018
LGTM |
pongad
commented
Mar 8, 2018
@garrettjonesgoogle \Do you also want to take a look? |
| private final Channel channel; | ||
| @Nullable private final CallCredentials callCredentials; | ||
| private final TopicAdminClient topicClient; |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
Uh oh!
There was an error while loading. Please reload this page.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
Uh oh!
There was an error while loading. Please reload this page.
| closeables = | ||
| Collections.<AutoCloseable>singletonList(new ExecutorAsBackgroundResource(executor)); | ||
| } else { | ||
| closeables = Collections.emptyList(); |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
Uh oh!
There was an error while loading. Please reload this page.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
Uh oh!
There was an error while loading. Please reload this page.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
Uh oh!
There was an error while loading. Please reload this page.
| try { | ||
| ApiException gaxException = | ||
| ApiExceptionFactory.createException( | ||
| t, GrpcStatusCode.of(Status.fromThrowable(t).getCode()), false); |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
Uh oh!
There was an error while loading. Please reload this page.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
Uh oh!
There was an error while loading. Please reload this page.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
Uh oh!
There was an error while loading. Please reload this page.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
Uh oh!
There was an error while loading. Please reload this page.
pongad
commented
Mar 13, 2018
@garrettjonesgoogle PTAL |
pongad
commented
Mar 14, 2018
@garrettjonesgoogle Committed the test now |
pongad
commented
Mar 14, 2018
Thank you @garrettjonesgoogle . Sorry for the churn. |
Co-authored-by: Phong Chuong <147636638+PhongChuong@users.noreply.github.com>
…-info-reports-plugin to v3.5.0 (#3008) * build(deps): update dependency org.apache.maven.plugins:maven-project-info-reports-plugin to v3.5.0 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md --------- Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
Co-authored-by: Phong Chuong <147636638+PhongChuong@users.noreply.github.com>
No description provided.