opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-21 05:44:03 +08:00
Code Issues Packages Projects Releases Wiki Activity

Update AsyncTraceDispatcher.java (#4509)

Browse Source 
fix issue 4507
This commit is contained in:
thezp
2022-06-25 11:50:12 +08:00
committed by GitHub
parent c204199e1d
commit d5b4d8431c
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
client/src/main/java/org/apache/rocketmq/client/trace/AsyncTraceDispatcher.java
+2 -2
View File
@@ -165,7 +165,7 @@ public class AsyncTraceDispatcher implements TraceDispatcher {
traceProducerInstance.setSendMsgTimeout(5000);
traceProducerInstance.setVipChannelEnabled(false);
// The max size of message is 128K
traceProducerInstance.setMaxMessageSize(maxMsgSize - 10 * 1000);
traceProducerInstance.setMaxMessageSize(maxMsgSize);
}
return traceProducerInstance;
}
@@ -324,7 +324,7 @@ public class AsyncTraceDispatcher implements TraceDispatcher {
initFirstBeanAddTime();
this.traceTransferBeanList.add(traceTransferBean);
this.currentMsgSize += traceTransferBean.getTransData().length();
if (currentMsgSize >= traceProducer.getMaxMessageSize()) {
if (currentMsgSize >= traceProducer.getMaxMessageSize() - 10 * 1000) {
List<TraceTransferBean> dataToSend = new ArrayList(traceTransferBeanList);
AsyncDataSendTask asyncDataSendTask = new AsyncDataSendTask(traceTopicName, regionId, dataToSend);
traceExecutor.submit(asyncDataSendTask);