private static void createTopic()

in src/main/java/com/googlesource/gerrit/plugins/pubsub/local/LocalPublisherProvider.java [61:76]

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

  private static void createTopic(ManagedChannel channel, String project, String topicId)
      throws IOException {

    TopicAdminSettings topicAdminSettings =
        TopicAdminSettings.newBuilder()
            .setTransportChannelProvider(
                FixedTransportChannelProvider.create(GrpcTransportChannel.create(channel)))
            .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
    }
  }