public LogAccumulator()

in src/main/java/com/aliyun/openservices/aliyun/log/producer/internals/LogAccumulator.java [49:71]

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

  public LogAccumulator(
      String producerHash,
      ProducerConfig producerConfig,
      Map<String, Client> clientPool,
      Semaphore memoryController,
      RetryQueue retryQueue,
      BlockingQueue<ProducerBatch> successQueue,
      BlockingQueue<ProducerBatch> failureQueue,
      IOThreadPool ioThreadPool,
      AtomicInteger batchCount) {
    this.producerHash = producerHash;
    this.producerConfig = producerConfig;
    this.clientPool = clientPool;
    this.memoryController = memoryController;
    this.retryQueue = retryQueue;
    this.successQueue = successQueue;
    this.failureQueue = failureQueue;
    this.ioThreadPool = ioThreadPool;
    this.batchCount = batchCount;
    this.batches = new ConcurrentHashMap<GroupKey, ProducerBatchHolder>();
    this.appendsInProgress = new AtomicInteger(0);
    this.closed = false;
  }