---

yoshi-automation · chingor13 · commit 3d629ba3526d · 2018-12-05T14:24:05.000-08:00
yaml --- r: 13073 b: refs/heads/autosynth-spanner c: f3d0703 h: refs/heads/master i: 13071: 3ccc4ad
diff --git a/[refs] b/[refs]
@@ -140,7 +140,7 @@ refs/heads/autosynth-os-login: daa910328b954bbe87068f684a3088ed910f1ddf
 refs/heads/autosynth-redis: 4c68cb0fbc599124e717ab3f24bd8a8a5d085ca9
 refs/heads/autosynth-scheduler: 2f0fe714a8541dc72f88b45bddd8748e5f21cf29
 refs/heads/autosynth-securitycenter: 8e95447ccb176c3648880ee0cb926cd1f4065156
-refs/heads/autosynth-spanner: 07348682bf2640969553fa7a64e309678ae533d6
+refs/heads/autosynth-spanner: f3d070350ae78d030012ec258ddfe32c7eb27c9d
 refs/heads/autosynth-speech: 631df42a628621fe42eb4974c9eb725b2fe8e473
 refs/heads/autosynth-tasks: afc9f4da54964dea5e7f3a9b164db282fc35db5c
 refs/heads/autosynth-texttospeech: a447278ab2ec3975aab3b641549c6780eac0a07a
diff --git a/branches/autosynth-spanner/google-cloud-clients/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/PublisherStubSettings.java b/branches/autosynth-spanner/google-cloud-clients/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/PublisherStubSettings.java
@@ -292,7 +292,9 @@ public String extractNextToken(ListTopicsResponse payload) {
 
             @Override
             public Iterable<Topic> extractResources(ListTopicsResponse payload) {
-              return payload.getTopicsList();
+              return payload.getTopicsList() != null
+                  ? payload.getTopicsList()
+                  : ImmutableList.<Topic>of();
             }
           };
 
@@ -332,7 +334,9 @@ public String extractNextToken(ListTopicSubscriptionsResponse payload) {
 
             @Override
             public Iterable<String> extractResources(ListTopicSubscriptionsResponse payload) {
-              return payload.getSubscriptionsList();
+              return payload.getSubscriptionsList() != null
+                  ? payload.getSubscriptionsList()
+                  : ImmutableList.<String>of();
             }
           };
 
@@ -476,11 +480,6 @@ public static class Builder extends StubSettings.Builder<PublisherStubSettings,
           ImmutableSet.copyOf(
               Lists.<StatusCode.Code>newArrayList(
                   StatusCode.Code.DEADLINE_EXCEEDED, StatusCode.Code.UNAVAILABLE)));
-      definitions.put(
-          "http_get",
-          ImmutableSet.copyOf(
-              Lists.<StatusCode.Code>newArrayList(
-                  StatusCode.Code.DEADLINE_EXCEEDED, StatusCode.Code.UNAVAILABLE)));
       definitions.put("non_idempotent", ImmutableSet.copyOf(Lists.<StatusCode.Code>newArrayList()));
       definitions.put(
           "one_plus_delivery",
diff --git a/branches/autosynth-spanner/google-cloud-clients/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SubscriberStubSettings.java b/branches/autosynth-spanner/google-cloud-clients/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SubscriberStubSettings.java
@@ -355,7 +355,9 @@ public String extractNextToken(ListSubscriptionsResponse payload) {
 
             @Override
             public Iterable<Subscription> extractResources(ListSubscriptionsResponse payload) {
-              return payload.getSubscriptionsList();
+              return payload.getSubscriptionsList() != null
+                  ? payload.getSubscriptionsList()
+                  : ImmutableList.<Subscription>of();
             }
           };
 
@@ -389,7 +391,9 @@ public String extractNextToken(ListSnapshotsResponse payload) {
 
             @Override
             public Iterable<Snapshot> extractResources(ListSnapshotsResponse payload) {
-              return payload.getSnapshotsList();
+              return payload.getSnapshotsList() != null
+                  ? payload.getSnapshotsList()
+                  : ImmutableList.<Snapshot>of();
             }
           };
 
@@ -484,11 +488,6 @@ public static class Builder extends StubSettings.Builder<SubscriberStubSettings,
                   StatusCode.Code.INTERNAL,
                   StatusCode.Code.RESOURCE_EXHAUSTED,
                   StatusCode.Code.UNAVAILABLE)));
-      definitions.put(
-          "http_get",
-          ImmutableSet.copyOf(
-              Lists.<StatusCode.Code>newArrayList(
-                  StatusCode.Code.DEADLINE_EXCEEDED, StatusCode.Code.UNAVAILABLE)));
       definitions.put("non_idempotent", ImmutableSet.copyOf(Lists.<StatusCode.Code>newArrayList()));
       RETRYABLE_CODE_DEFINITIONS = definitions.build();
     }
diff --git a/branches/autosynth-spanner/google-cloud-clients/google-cloud-pubsub/synth.py b/branches/autosynth-spanner/google-cloud-clients/google-cloud-pubsub/synth.py
@@ -35,6 +35,12 @@
   s.copy(library / f'grpc-google-cloud-{service}-{version}/src', f'../../google-api-grpc/grpc-google-cloud-{service}-{version}/src')
   s.copy(library / f'proto-google-cloud-{service}-{version}/src', f'../../google-api-grpc/proto-google-cloud-{service}-{version}/src')
 
+  s.replace(
+      '**/stub/SubscriberStubSettings.java',
+      r'return InstantiatingGrpcChannelProvider\.newBuilder\(\);',
+      'return InstantiatingGrpcChannelProvider.newBuilder().setMaxInboundMessageSize(20 << 20); // 20MB'
+  )
+
   java.format_code('./src')
   java.format_code(f'../../google-api-grpc/grpc-google-cloud-{service}-{version}/src')
   java.format_code(f'../../google-api-grpc/proto-google-cloud-{service}-{version}/src')
