|
30 | 30 | import com.google.containeranalysis.v1alpha1.Occurrence; |
31 | 31 | import com.google.containeranalysis.v1alpha1.VulnerabilityType; |
32 | 32 | import com.google.containeranalysis.v1alpha1.VulnerabilityType.VulnerabilityDetails; |
| 33 | +import com.google.pubsub.v1.ProjectSubscriptionName; |
| 34 | +import com.google.pubsub.v1.ProjectTopicName; |
33 | 35 | import com.google.pubsub.v1.PubsubMessage; |
34 | 36 | import com.google.pubsub.v1.PushConfig; |
35 | 37 | import com.google.pubsub.v1.Subscription; |
36 | | -import com.google.pubsub.v1.SubscriptionName; |
37 | | -import com.google.pubsub.v1.TopicName; |
38 | 38 |
|
39 | 39 | /** |
40 | 40 | * API usage samples |
@@ -292,7 +292,7 @@ public static int pubSub(String subscriptionId, int timeout, String projectId) t |
292 | 292 |
|
293 | 293 | try { |
294 | 294 | // subscribe to the requested pubsub channel |
295 | | - SubscriptionName subscriptionName = SubscriptionName.of(projectId, subscriptionId); |
| 295 | + ProjectSubscriptionName subscriptionName = ProjectSubscriptionName.of(projectId, subscriptionId); |
296 | 296 | subscriber = Subscriber.newBuilder(subscriptionName, receiver).build(); |
297 | 297 | subscriber.startAsync().awaitRunning(); |
298 | 298 | // listen to messages for 'listenTimeout' seconds |
@@ -339,8 +339,8 @@ public static Subscription createOccurrenceSubscription(String subscriptionId, S |
339 | 339 | String topicId = "resource-notes-occurrences-v1alpha1"; |
340 | 340 | try (SubscriptionAdminClient client = SubscriptionAdminClient.create()) { |
341 | 341 | PushConfig config = PushConfig.getDefaultInstance(); |
342 | | - TopicName topicName = TopicName.of(projectId, topicId); |
343 | | - SubscriptionName subscriptionName = SubscriptionName.of(projectId, subscriptionId); |
| 342 | + ProjectTopicName topicName = ProjectTopicName.of(projectId, topicId); |
| 343 | + ProjectSubscriptionName subscriptionName = ProjectSubscriptionName.of(projectId, subscriptionId); |
344 | 344 | Subscription sub = client.createSubscription(subscriptionName, topicName, config, 0); |
345 | 345 | return sub; |
346 | 346 | } |
|
0 commit comments