private static void createTopic()

in src/main/java/com/googlesource/gerrit/plugins/pubsub/local/LocalSubscriberProvider.java [82:96]

• 13 lines of code
• 2 McCabe index (conditional complexity)

  private static void createTopic(
      TransportChannelProvider channelProvider, String project, String topicId) throws IOException {

    TopicAdminSettings topicAdminSettings =
        TopicAdminSettings.newBuilder()
            .setTransportChannelProvider(channelProvider)
            .setCredentialsProvider(NoCredentialsProvider.create())
            .build();
    try (TopicAdminClient topicAdminClient = TopicAdminClient.create(topicAdminSettings)) {
      TopicName topicName = TopicName.of(project, topicId);
      topicAdminClient.createTopic(topicName);
    } catch (AlreadyExistsException e) {
      // topic already exists do nothing
    }
  }