File tree Expand file tree Collapse file tree
branches/autosynth-containeranalysis/google-cloud-examples/src/test/java/com/google/cloud/examples/pubsub/snippets Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -126,7 +126,7 @@ refs/heads/autosynth-bigquerydatatransfer: 71b6b6d2a992d05999b53e6e130c4fc1c8c8b
126126refs/heads/autosynth-bigquerystorage: a345f72d7a6358e9fea9dcdae94ec85a27da3088
127127refs/heads/autosynth-bigtable: 2a6af7e2959fd79c99b8ca5d773f29a6434b546d
128128refs/heads/autosynth-bigtable-admin: 6379a2bc712f2736c83de0e009b4d26da4fa82ca
129- refs/heads/autosynth-containeranalysis: 080b6be2af3922c8c2a2ff8702b3bb49f7622972
129+ refs/heads/autosynth-containeranalysis: 661e461ee6ccf957bb8741cb807c6f63be4ce69f
130130refs/heads/autosynth-datastore: d0fc1187000c7a50d8bddd89c3b7cdf1187ecb96
131131refs/heads/autosynth-dialogflow: 841930a680ebe370c9fc6ae824465f6bc51a5a46
132132refs/heads/autosynth-errorreporting: 3f176c20b55dfaaa8fc32f28d82b31784b93e636
Original file line number Diff line number Diff line change 2727import com .google .cloud .pubsub .v1 .Publisher ;
2828import com .google .cloud .pubsub .v1 .SubscriptionAdminClient ;
2929import com .google .cloud .pubsub .v1 .TopicAdminClient ;
30+ import com .google .common .util .concurrent .MoreExecutors ;
3031import com .google .pubsub .v1 .ProjectSubscriptionName ;
3132import com .google .pubsub .v1 .ProjectTopicName ;
3233import 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 ) {
You can’t perform that action at this time.
0 commit comments