private Acker()

in src/main/java/com/spotify/google/cloud/pubsub/client/Acker.java [78:91]

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

  private Acker(final Builder builder) {
    this.pubsub = Objects.requireNonNull(builder.pubsub, "pubsub");
    this.project = Objects.requireNonNull(builder.project, "project");
    this.subscription = Objects.requireNonNull(builder.subscription, "subscription");
    this.batchSize = builder.batchSize;
    this.queueSize = Optional.ofNullable(builder.queueSize).orElseGet(() -> batchSize * 10);
    this.maxLatencyMs = builder.maxLatencyMs;
    this.concurrency = builder.concurrency;

    this.backoff = Backoff.builder()
        .initialInterval(builder.maxLatencyMs)
        .maxBackoffMultiplier(builder.maxBackoffMultiplier)
        .build();
  }