in src/main/java/com/aliyun/openservices/aliyun/log/producer/internals/ProducerBatch.java [46:62]
public ProducerBatch(
GroupKey groupKey,
String packageId,
int batchSizeThresholdInBytes,
int batchCountThreshold,
int maxReservedAttempts,
long nowMs) {
this.groupKey = groupKey;
this.packageId = packageId;
this.createdMs = nowMs;
this.batchSizeThresholdInBytes = batchSizeThresholdInBytes;
this.batchCountThreshold = batchCountThreshold;
this.curBatchCount = 0;
this.curBatchSizeInBytes = 0;
this.reservedAttempts = EvictingQueue.create(maxReservedAttempts);
this.attemptCount = 0;
}