public Publisher get()

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

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

  public Publisher get(String topic) throws IOException {
    ManagedChannel channel =
        ManagedChannelBuilder.forTarget(environmentChecker.getLocalHostAndPort().get())
            .usePlaintext()
            .build();
    TransportChannelProvider channelProvider =
        FixedTransportChannelProvider.create(GrpcTransportChannel.create(channel));
    createTopic(channel, config.getGCloudProject(), topic);
    return Publisher.newBuilder(TopicName.of(config.getGCloudProject(), topic))
        .setChannelProvider(channelProvider)
        .setCredentialsProvider(credentials)
        .build();
  }