protected final Publisher newInstance()

in app/common/src/main/java/com/googlecodesamples/cloud/jss/common/factory/BasePublisherFactory.java [52:70]

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

  protected final Publisher newInstance() throws IOException {
    TopicName topicName = TopicName.of(PubSubUtil.getEnvProjectId(), getConfig().getTopicName());
    Publisher.Builder builder = Publisher.newBuilder(topicName);
    BatchingSettings batchSettings = getBatchSettings();
    if (batchSettings != null) {
      builder.setBatchingSettings(batchSettings);
    }

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

    RetrySettings retrySettings = getRetrySetting();
    if (retrySettings != null) {
      builder.setRetrySettings(retrySettings);
    }
    return builder.build();
  }