---

pongad · web-flow · commit b1143ddfe6ca · 2018-01-06T15:11:50.000+11:00
yaml --- r: 8609 b: refs/heads/master c: 99e510d h: refs/heads/master i: 8607: a5e18b5
diff --git a/[refs] b/[refs]
@@ -1,5 +1,5 @@
 ---
-refs/heads/master: 6e3f26bfe225917d9e0815a4982755d7337fa3ef
+refs/heads/master: 99e510d3fcc1d6cb27ab83fdd742e74329217013
 refs/heads/travis: 47e4fee4fd5af9b2a8ce46f23c72ec95f9b195b2
 refs/heads/gh-pages: 6daca92127d91b7c2c99490080ecf8a13fa94cde
 refs/tags/0.0.9: 22f1839238f66c39e67ed4dfdcd273b1ae2e8444
diff --git a/trunk/google-cloud-logging/src/main/java/com/google/cloud/logging/spi/v2/GrpcLoggingRpc.java b/trunk/google-cloud-logging/src/main/java/com/google/cloud/logging/spi/v2/GrpcLoggingRpc.java
@@ -19,6 +19,8 @@
 import com.google.api.core.ApiFunction;
 import com.google.api.core.ApiFuture;
 import com.google.api.core.ApiFutures;
+import com.google.api.gax.batching.BatchingSettings;
+import com.google.api.gax.batching.FlowController.LimitExceededBehavior;
 import com.google.api.gax.core.BackgroundResource;
 import com.google.api.gax.core.GaxProperties;
 import com.google.api.gax.grpc.GrpcCallContext;
@@ -138,6 +140,24 @@ public Void apply(UnaryCallSettings.Builder<?, ?> builder) {
           LoggingSettings.newBuilder(clientContext).applyToAllUnaryMethods(retrySettingsSetter);
       MetricsSettings.Builder metricsBuilder =
           MetricsSettings.newBuilder(clientContext).applyToAllUnaryMethods(retrySettingsSetter);
+
+      // TODO(pongad): Take advantage of https://github.com/googleapis/gax-java/pull/452 when it's
+      // released.
+      BatchingSettings oldBatchSettings =
+          logBuilder.writeLogEntriesSettings().getBatchingSettings();
+      logBuilder
+          .writeLogEntriesSettings()
+          .setBatchingSettings(
+              oldBatchSettings
+                  .toBuilder()
+                  .setFlowControlSettings(
+                      oldBatchSettings
+                          .getFlowControlSettings()
+                          .toBuilder()
+                          .setLimitExceededBehavior(LimitExceededBehavior.Block)
+                          .build())
+                  .build());
+
       configClient = ConfigClient.create(confBuilder.build());
       loggingClient = LoggingClient.create(logBuilder.build());
       metricsClient = MetricsClient.create(metricsBuilder.build());
