Skip to content

Commit cf5c085

Browse files
abhinav-qlogicsduskis
authored andcommitted
---
yaml --- r: 31711 b: refs/heads/autosynth-containeranalysis c: 661e461 h: refs/heads/master i: 31709: 1ddc741 31707: 4126558 31703: a8fec79 31695: 0711361 31679: 03c8540
1 parent 2143783 commit cf5c085

2 files changed

Lines changed: 4 additions & 2 deletions

File tree

  • branches/autosynth-containeranalysis/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
@@ -126,7 +126,7 @@ refs/heads/autosynth-bigquerydatatransfer: 71b6b6d2a992d05999b53e6e130c4fc1c8c8b
126126
refs/heads/autosynth-bigquerystorage: a345f72d7a6358e9fea9dcdae94ec85a27da3088
127127
refs/heads/autosynth-bigtable: 2a6af7e2959fd79c99b8ca5d773f29a6434b546d
128128
refs/heads/autosynth-bigtable-admin: 6379a2bc712f2736c83de0e009b4d26da4fa82ca
129-
refs/heads/autosynth-containeranalysis: 080b6be2af3922c8c2a2ff8702b3bb49f7622972
129+
refs/heads/autosynth-containeranalysis: 661e461ee6ccf957bb8741cb807c6f63be4ce69f
130130
refs/heads/autosynth-datastore: d0fc1187000c7a50d8bddd89c3b7cdf1187ecb96
131131
refs/heads/autosynth-dialogflow: 841930a680ebe370c9fc6ae824465f6bc51a5a46
132132
refs/heads/autosynth-errorreporting: 3f176c20b55dfaaa8fc32f28d82b31784b93e636

branches/autosynth-containeranalysis/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)