21
21
import com .google .cloud .ServiceOptions ;
22
22
import com .google .cloud .pubsub .v1 .SubscriptionAdminClient ;
23
23
import com .google .cloud .pubsub .v1 .TopicAdminClient ;
24
- import com .google .pubsub .v1 .SubscriptionName ;
25
- import com .google .pubsub .v1 .TopicName ;
24
+ import com .google .pubsub .v1 .ProjectSubscriptionName ;
25
+ import com .google .pubsub .v1 .ProjectTopicName ;
26
26
import java .io .ByteArrayOutputStream ;
27
27
import java .io .IOException ;
28
28
import java .io .PrintStream ;
@@ -133,7 +133,7 @@ private String formatForTest(String name) {
133
133
134
134
private void deleteTestTopic () throws Exception {
135
135
try (TopicAdminClient topicAdminClient = TopicAdminClient .create ()) {
136
- topicAdminClient .deleteTopic (TopicName .of (projectId , topicId ));
136
+ topicAdminClient .deleteTopic (ProjectTopicName .of (projectId , topicId ));
137
137
} catch (IOException e ) {
138
138
System .err .println ("Error deleting topic " + e .getMessage ());
139
139
}
@@ -142,7 +142,7 @@ private void deleteTestTopic() throws Exception {
142
142
private void deleteTestSubscription () throws Exception {
143
143
try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient .create ()) {
144
144
subscriptionAdminClient .deleteSubscription (
145
- SubscriptionName .of (projectId , subscriptionId ));
145
+ ProjectSubscriptionName .of (projectId , subscriptionId ));
146
146
} catch (IOException e ) {
147
147
System .err .println ("Error deleting subscription " + e .getMessage ());
148
148
}
0 commit comments