We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 594031a commit e2f4ed7Copy full SHA for e2f4ed7
arex-instrumentation-api/src/main/java/io/arex/inst/runtime/util/MergeRecordUtil.java
@@ -14,7 +14,9 @@
14
import java.util.concurrent.LinkedBlockingQueue;
15
16
/**
17
- * merge record
+ * To solve the problem of insufficient consume capacity of downstream DataServices.
18
+ * by controlling the speed at which producers produce mockers.
19
+ * multiple producer -> single consumer
20
*/
21
public class MergeRecordUtil {
22
private static final AgentSizeOf agentSizeOf = AgentSizeOf.newInstance();
0 commit comments