Skip to content

Commit e64079b

Browse files
abhinav-qlogicsduskis
authored andcommitted
---
yaml --- r: 29945 b: refs/heads/autosynth-video-intelligence c: 661e461 h: refs/heads/master i: 29943: d88a285
1 parent cf12591 commit e64079b

2 files changed

Lines changed: 4 additions & 2 deletions

File tree

  • branches/autosynth-video-intelligence/google-cloud-examples/src/test/java/com/google/cloud/examples/pubsub/snippets

[refs]

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -115,7 +115,7 @@ refs/heads/autosynth-compute: c0ad4e5b54b2b167d47e508ca215c039404837d3
115115
refs/heads/autosynth-container: e9a9a8564756e20770320ed54eafa867040a7690
116116
refs/heads/autosynth-monitoring: f3b29d97f847cecd186ec14aeee04a232aaf0e1b
117117
refs/heads/autosynth-pubsub: 7cb1cf88e2e0731dbdfb4540a0dce7fb33f71c93
118-
refs/heads/autosynth-video-intelligence: 080b6be2af3922c8c2a2ff8702b3bb49f7622972
118+
refs/heads/autosynth-video-intelligence: 661e461ee6ccf957bb8741cb807c6f63be4ce69f
119119
refs/heads/autosynth-vision: 01ef61bcef344ceee0198f56f18bc1db20201261
120120
refs/heads/spanner: b01127f885b4611bf1852abb0ce481eeb7fcc131
121121
refs/tags/v0.68.0: 9cc799fcf68c82ab431d425fefa58ef615ce8e5b

branches/autosynth-video-intelligence/google-cloud-examples/src/test/java/com/google/cloud/examples/pubsub/snippets/ITPubSubSnippets.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,7 @@
2727
import com.google.cloud.pubsub.v1.Publisher;
2828
import com.google.cloud.pubsub.v1.SubscriptionAdminClient;
2929
import com.google.cloud.pubsub.v1.TopicAdminClient;
30+
import com.google.common.util.concurrent.MoreExecutors;
3031
import com.google.pubsub.v1.ProjectSubscriptionName;
3132
import com.google.pubsub.v1.ProjectTopicName;
3233
import com.google.pubsub.v1.PubsubMessage;
@@ -92,7 +93,8 @@ public void onSuccess(String messageId) {
9293
public void onFailure(Throwable t) {
9394
done.setException(t);
9495
}
95-
});
96+
},
97+
MoreExecutors.directExecutor());
9698
done.get();
9799
} finally {
98100
if (publisher != null) {

0 commit comments

Comments
 (0)