public Mover()

in src/main/java/com/aliyun/openservices/aliyun/log/producer/internals/Mover.java [34:54]

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

  public Mover(
      String name,
      ProducerConfig producerConfig,
      Map<String, Client> clientPool,
      LogAccumulator accumulator,
      RetryQueue retryQueue,
      BlockingQueue<ProducerBatch> successQueue,
      BlockingQueue<ProducerBatch> failureQueue,
      IOThreadPool ioThreadPool,
      AtomicInteger batchCount) {
    super(name, true);
    this.producerConfig = producerConfig;
    this.clientPool = clientPool;
    this.accumulator = accumulator;
    this.retryQueue = retryQueue;
    this.successQueue = successQueue;
    this.failureQueue = failureQueue;
    this.ioThreadPool = ioThreadPool;
    this.batchCount = batchCount;
    this.closed = false;
  }