We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 080b6be commit 661e461Copy full SHA for 661e461
1 file changed
google-cloud-examples/src/test/java/com/google/cloud/examples/pubsub/snippets/ITPubSubSnippets.java
@@ -27,6 +27,7 @@
27
import com.google.cloud.pubsub.v1.Publisher;
28
import com.google.cloud.pubsub.v1.SubscriptionAdminClient;
29
import com.google.cloud.pubsub.v1.TopicAdminClient;
30
+import com.google.common.util.concurrent.MoreExecutors;
31
import com.google.pubsub.v1.ProjectSubscriptionName;
32
import com.google.pubsub.v1.ProjectTopicName;
33
import com.google.pubsub.v1.PubsubMessage;
@@ -92,7 +93,8 @@ public void onSuccess(String messageId) {
92
93
public void onFailure(Throwable t) {
94
done.setException(t);
95
}
- });
96
+ },
97
+ MoreExecutors.directExecutor());
98
done.get();
99
} finally {
100
if (publisher != null) {
0 commit comments