---

abhinav-qlogic · sduskis · commit 5140fff4e4a1 · 2019-06-11T11:44:44.000-04:00
yaml --- r: 33109 b: refs/heads/autosynth-kms c: 661e461 h: refs/heads/master i: 33107: 28a7c81
diff --git a/[refs] b/[refs]
@@ -132,7 +132,7 @@ refs/heads/autosynth-dialogflow: 73974cc32e5212aec0126472e0bc1442886fedaf
 refs/heads/autosynth-errorreporting: effe8001d110ad584187b30aafc473db0dd4a15f
 refs/heads/autosynth-firestore: e79eeb26930dfae4439424ad2fda5874eeca54c8
 refs/heads/autosynth-iot: 044be280805a59e06d09658688c9ee474a9815ad
-refs/heads/autosynth-kms: 080b6be2af3922c8c2a2ff8702b3bb49f7622972
+refs/heads/autosynth-kms: 661e461ee6ccf957bb8741cb807c6f63be4ce69f
 refs/heads/autosynth-language: e73905aa7672afa47240e65b25c087207f4594f9
 refs/heads/autosynth-os-login: 123ba209c5769d0ee067e0ce5848bec13b42a4f4
 refs/heads/autosynth-redis: 6bedce4d7c7c6ca6a22e83ad1780e08fdc565a9e
diff --git a/branches/autosynth-kms/google-cloud-examples/src/test/java/com/google/cloud/examples/pubsub/snippets/ITPubSubSnippets.java b/branches/autosynth-kms/google-cloud-examples/src/test/java/com/google/cloud/examples/pubsub/snippets/ITPubSubSnippets.java
@@ -27,6 +27,7 @@
 import com.google.cloud.pubsub.v1.Publisher;
 import com.google.cloud.pubsub.v1.SubscriptionAdminClient;
 import com.google.cloud.pubsub.v1.TopicAdminClient;
+import com.google.common.util.concurrent.MoreExecutors;
 import com.google.pubsub.v1.ProjectSubscriptionName;
 import com.google.pubsub.v1.ProjectTopicName;
 import com.google.pubsub.v1.PubsubMessage;
@@ -92,7 +93,8 @@ public void onSuccess(String messageId) {
             public void onFailure(Throwable t) {
               done.setException(t);
             }
-          });
+          },
+          MoreExecutors.directExecutor());
       done.get();
     } finally {
       if (publisher != null) {
