protected Subscriber newInstance()

in app/common/src/main/java/com/googlecodesamples/cloud/jss/common/factory/BaseSubscriberFactory.java [69:89]

• 19 lines of code
• 4 McCabe index (conditional complexity)

  protected Subscriber newInstance(MessageReceiver receiver) {
    ProjectSubscriptionName subscriptionName =
        ProjectSubscriptionName.of(
            PubSubUtil.getEnvProjectId(), getConfig().getEventSubscription());
    Subscriber.Builder builder = Subscriber.newBuilder(subscriptionName.toString(), receiver);
    FlowControlSettings flowControlSettings = getFlowControlSettings();
    if (flowControlSettings != null) {
      builder.setFlowControlSettings(flowControlSettings);
    }

    provider = getExecutorProvider();
    if (provider != null) {
      builder.setExecutorProvider(provider);
    }

    Integer parallelPull = getConfig().getParallelPull();
    if (parallelPull != null) {
      builder.setParallelPullCount(parallelPull);
    }
    return builder.build();
  }