---

anguillanneuf · chingor13 · commit f7d8b68b1c98 · 2018-12-03T13:16:06.000-08:00
yaml --- r: 13059 b: refs/heads/autosynth-spanner c: 50a8533 h: refs/heads/master i: 13057: c44b7d4 13055: 7910297
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: 969bbeef18f004fd51fd46c5def1ae5c644cae3c
+refs/heads/autosynth-spanner: 50a853325b306f27c46026e77976ebbfb7dc0106
 refs/heads/autosynth-speech: 631df42a628621fe42eb4974c9eb725b2fe8e473
 refs/heads/autosynth-tasks: afc9f4da54964dea5e7f3a9b164db282fc35db5c
 refs/heads/autosynth-texttospeech: a447278ab2ec3975aab3b641549c6780eac0a07a
diff --git a/branches/autosynth-spanner/google-cloud-examples/src/main/java/com/google/cloud/examples/pubsub/snippets/CreateTopicAndPublishMessages.java b/branches/autosynth-spanner/google-cloud-examples/src/main/java/com/google/cloud/examples/pubsub/snippets/CreateTopicAndPublishMessages.java
@@ -22,6 +22,7 @@
 import com.google.api.gax.rpc.ApiException;
 import com.google.cloud.pubsub.v1.Publisher;
 import com.google.cloud.pubsub.v1.TopicAdminClient;
+import com.google.common.util.concurrent.MoreExecutors;
 import com.google.protobuf.ByteString;
 import com.google.pubsub.v1.ProjectTopicName;
 import com.google.pubsub.v1.PubsubMessage;
@@ -120,7 +121,8 @@ public void onSuccess(String messageId) {
                 // Once published, returns server-assigned message ids (unique within the topic)
                 System.out.println(messageId);
               }
-            });
+            },
+            MoreExecutors.directExecutor());
       }
     } finally {
       if (publisher != null) {
