in src/main/java/com/aliyun/openservices/aliyun/log/producer/internals/SendProducerBatchTask.java [42:57]
public SendProducerBatchTask(
ProducerBatch batch,
ProducerConfig producerConfig,
Map<String, Client> clientPool,
RetryQueue retryQueue,
BlockingQueue<ProducerBatch> successQueue,
BlockingQueue<ProducerBatch> failureQueue,
AtomicInteger batchCount) {
this.batch = batch;
this.producerConfig = producerConfig;
this.clientPool = clientPool;
this.retryQueue = retryQueue;
this.successQueue = successQueue;
this.failureQueue = failureQueue;
this.batchCount = batchCount;
}