public void sendOrRecvMsg(String topic, long dltTime,
                int msgCnt, int msgSize) {
            msgCallDltStats.update(dltTime);
            totalTrafficStats.addMsgCntAndSize(msgCnt, msgSize);
            // accumulate traffic information by topic
            TrafficStatsUnit curStatsUnit = topicTrafficMap.get(topic);
            if (curStatsUnit == null) {
                TrafficStatsUnit tmpUnit =
                        new TrafficStatsUnit("msg_cnt", "msg_size", topic);
                curStatsUnit = topicTrafficMap.putIfAbsent(topic, tmpUnit);
                if (curStatsUnit == null) {
                    curStatsUnit = tmpUnit;
                }
            }
            curStatsUnit.addMsgCntAndSize(msgCnt, msgSize);
        }
Accumulate sent or received message information

@param topic     the topic name
@param dltTime   the latency
@param msgCnt    the message count
@param msgSize   the message size
inlong-tubemq/tubemq-client/src/main/java/org/apache/inlong/tubemq/client/common/ClientStatsInfo.java