Skip to content

Commit 38449cb

Browse files
committed
pubsub: fix publish doc
Fixes #2064.
1 parent 7a43064 commit 38449cb

1 file changed

Lines changed: 4 additions & 4 deletions

File tree

  • google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1

google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/Publisher.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -16,16 +16,16 @@
1616

1717
package com.google.cloud.pubsub.spi.v1;
1818

19-
import com.google.api.gax.batching.BatchingSettings;
2019
import com.google.api.core.ApiFuture;
2120
import com.google.api.core.ApiFutures;
21+
import com.google.api.core.SettableApiFuture;
22+
import com.google.api.gax.batching.BatchingSettings;
2223
import com.google.api.gax.batching.FlowControlSettings;
2324
import com.google.api.gax.batching.FlowController;
24-
import com.google.api.gax.retrying.RetrySettings;
25-
import com.google.api.core.SettableApiFuture;
2625
import com.google.api.gax.grpc.ChannelProvider;
2726
import com.google.api.gax.grpc.ExecutorProvider;
2827
import com.google.api.gax.grpc.InstantiatingExecutorProvider;
28+
import com.google.api.gax.retrying.RetrySettings;
2929
import com.google.auth.oauth2.GoogleCredentials;
3030
import com.google.common.annotations.VisibleForTesting;
3131
import com.google.common.base.Preconditions;
@@ -180,7 +180,7 @@ public TopicName getTopicName() {
180180
* ByteString data = ByteString.copyFromUtf8(message);
181181
* PubsubMessage pubsubMessage = PubsubMessage.newBuilder().setData(data).build();
182182
* ApiFuture<String> messageIdFuture = publisher.publish(pubsubMessage);
183-
* messageIdFuture.addCallback(new ApiFutureCallback<String>() {
183+
* ApiFutures.addCallback(messageIdFuture, new ApiFutureCallback<String>() {
184184
* public void onSuccess(String messageId) {
185185
* System.out.println("published with message id: " + messageId);
186186
* }

0 commit comments

Comments
 (0)