create new topic if needed

Author: daniel-sanche

container-registry/container-analysis/src/test/java/com/example/containeranalysis/SamplesTest.java

@@ -23,7 +23,9 @@
 import com.google.cloud.devtools.containeranalysis.v1.ContainerAnalysisClient;
 import com.google.cloud.pubsub.v1.Subscriber;
 import com.google.cloud.pubsub.v1.SubscriptionAdminClient;
+import com.google.cloud.pubsub.v1.TopicAdminClient;
 import com.google.pubsub.v1.ProjectSubscriptionName;
+import com.google.pubsub.v1.ProjectTopicName;
 import io.grafeas.v1.DiscoveryNote;
 import io.grafeas.v1.DiscoveryOccurrence;
 import io.grafeas.v1.DiscoveryOccurrence.AnalysisStatus;
@@ -202,6 +204,14 @@ public void testOccurrencesForNote() throws Exception {
   public void testPubSub() throws Exception {
     int newCount;
     int tries;
+    // create new topic and subscription if needed
+    try (TopicAdminClient topicAdminClient = TopicAdminClient.create()) {
+      String topicId = "container-analysis-occurrences-v1";
+      ProjectTopicName topicName = ProjectTopicName.of(PROJECT_ID, topicId);
+      topicAdminClient.createTopic(topicName);
+    } catch (StatusRuntimeException e) {
+      System.out.println("Topic already exists");
+    }
     ProjectSubscriptionName subName = ProjectSubscriptionName.of(PROJECT_ID, subId);
     try {
       Subscriptions.createOccurrenceSubscription(subId, PROJECT_ID);