public Subscriber get()

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

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

  public Subscriber get(String topic, MessageReceiver receiver) throws IOException {
    TransportChannelProvider channelProvider = createChannelProvider();
    createTopic(channelProvider, pubSubProperties.getGCloudProject(), topic);
    return Subscriber.newBuilder(getOrCreateSubscription(topic).getName(), receiver)
        .setChannelProvider(channelProvider)
        .setExecutorProvider(FixedExecutorProvider.create(executor))
        .setCredentialsProvider(credentials)
        .build();
  }