void transferProducerBatch()

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

• 22 lines of code
• 2 McCabe index (conditional complexity)

    void transferProducerBatch(
        IOThreadPool ioThreadPool,
        ProducerConfig producerConfig,
        Map<String, Client> clientPool,
        RetryQueue retryQueue,
        BlockingQueue<ProducerBatch> successQueue,
        BlockingQueue<ProducerBatch> failureQueue,
        AtomicInteger batchCount) {
      if (producerBatch == null) {
        return;
      }
      ioThreadPool.submit(
          new SendProducerBatchTask(
              producerBatch,
              producerConfig,
              clientPool,
              retryQueue,
              successQueue,
              failureQueue,
              batchCount));
      producerBatch = null;
    }