---

abhinav-qlogic · sduskis · commit 7187f6b96ba9 · 2019-06-11T11:44:44.000-04:00
yaml --- r: 30905 b: refs/heads/autosynth-bigquerydatatransfer c: 661e461 h: refs/heads/master i: 30903: 6fc6870
diff --git a/[refs] b/[refs]
@@ -122,7 +122,7 @@ refs/tags/v0.68.0: 9cc799fcf68c82ab431d425fefa58ef615ce8e5b
 refs/tags/v0.69.0: 78f67a29e8b9c46ba01de566a2eae0fd1c03edea
 refs/heads/autosynth-asset: bdb45634a0fe8f7a510692b56b31f5312e25f453
 refs/heads/autosynth-automl: 22f9dd5b6f5df8dbfa7da0126864d565229519b2
-refs/heads/autosynth-bigquerydatatransfer: 080b6be2af3922c8c2a2ff8702b3bb49f7622972
+refs/heads/autosynth-bigquerydatatransfer: 661e461ee6ccf957bb8741cb807c6f63be4ce69f
 refs/heads/autosynth-bigquerystorage: d2c53da3b012e38c662e4df0738042435f19365f
 refs/heads/autosynth-bigtable: 9e5429f45cf9face9fed585d0233534993e36b58
 refs/heads/autosynth-bigtable-admin: 6379a2bc712f2736c83de0e009b4d26da4fa82ca
diff --git a/branches/autosynth-bigquerydatatransfer/google-cloud-examples/src/test/java/com/google/cloud/examples/pubsub/snippets/ITPubSubSnippets.java b/branches/autosynth-bigquerydatatransfer/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) {
