|
16 | 16 |
|
17 | 17 | package com.google.cloud.pubsub.spi.v1; |
18 | 18 |
|
19 | | -import com.google.api.gax.batching.BatchingSettings; |
20 | 19 | import com.google.api.core.ApiFuture; |
21 | 20 | import com.google.api.core.ApiFutures; |
| 21 | +import com.google.api.core.SettableApiFuture; |
| 22 | +import com.google.api.gax.batching.BatchingSettings; |
22 | 23 | import com.google.api.gax.batching.FlowControlSettings; |
23 | 24 | import com.google.api.gax.batching.FlowController; |
24 | | -import com.google.api.gax.retrying.RetrySettings; |
25 | | -import com.google.api.core.SettableApiFuture; |
26 | 25 | import com.google.api.gax.grpc.ChannelProvider; |
27 | 26 | import com.google.api.gax.grpc.ExecutorProvider; |
28 | 27 | import com.google.api.gax.grpc.InstantiatingExecutorProvider; |
| 28 | +import com.google.api.gax.retrying.RetrySettings; |
29 | 29 | import com.google.auth.oauth2.GoogleCredentials; |
30 | 30 | import com.google.common.annotations.VisibleForTesting; |
31 | 31 | import com.google.common.base.Preconditions; |
@@ -180,7 +180,7 @@ public TopicName getTopicName() { |
180 | 180 | * ByteString data = ByteString.copyFromUtf8(message); |
181 | 181 | * PubsubMessage pubsubMessage = PubsubMessage.newBuilder().setData(data).build(); |
182 | 182 | * ApiFuture<String> messageIdFuture = publisher.publish(pubsubMessage); |
183 | | - * messageIdFuture.addCallback(new ApiFutureCallback<String>() { |
| 183 | + * ApiFutures.addCallback(messageIdFuture, new ApiFutureCallback<String>() { |
184 | 184 | * public void onSuccess(String messageId) { |
185 | 185 | * System.out.println("published with message id: " + messageId); |
186 | 186 | * } |
|
0 commit comments