From fc861024c368c7163e982a19bc2194b1ebb948b3 Mon Sep 17 00:00:00 2001 From: lnk Date: Thu, 30 Apr 2026 16:06:29 +0800 Subject: [PATCH] fix bug in test mq --- cfg_parse/SimpleProducer.cpp | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/cfg_parse/SimpleProducer.cpp b/cfg_parse/SimpleProducer.cpp index 29f4605..64b9334 100644 --- a/cfg_parse/SimpleProducer.cpp +++ b/cfg_parse/SimpleProducer.cpp @@ -970,7 +970,7 @@ void rocketmq_test_rt() buffer << file.rdbuf(); // 读取整个文件内容 data.strText = QString::fromStdString(buffer.str()); - data.mp_id = 123123; + data.mp_id = QString::number(123456); my_rocketmq_send(data); } //extern std::string G_MQCONSUMER_TOPIC_UD; @@ -984,7 +984,7 @@ void rocketmq_test_ud()//用来测试台账更新 buffer << file.rdbuf(); // 读取整个文件内容 data.strText = QString::fromStdString(buffer.str()); - data.mp_id = 123123; + data.mp_id = QString::number(123456); my_rocketmq_send(data); } @@ -998,7 +998,7 @@ void rocketmq_test_set()//用来测试进程控制脚本 buffer << file.rdbuf(); // 读取整个文件内容 data.strText = QString::fromStdString(buffer.str()); - data.mp_id = 123123; + data.mp_id = QString::number(123456); my_rocketmq_send(data); } @@ -1012,7 +1012,7 @@ void rocketmq_test_only()//用来测试进程控制脚本 buffer << file.rdbuf(); // 读取整个文件内容 data.strText = QString::fromStdString(buffer.str()); - data.mp_id = 123123; + data.mp_id = QString::number(123456); my_rocketmq_send(data); } @@ -1027,7 +1027,7 @@ void rocketmq_test_rc() buffer << file.rdbuf(); // 读取整个文件内容 data.strText = QString::fromStdString(buffer.str()); - data.mp_id = 123123; + data.mp_id = QString::number(123456); my_rocketmq_send(data); } @@ -1042,7 +1042,7 @@ void rocketmq_test_log() buffer << file.rdbuf(); // 读取整个文件内容 data.strText = QString::fromStdString(buffer.str()); - data.mp_id = 123123; + data.mp_id = QString::number(123456); my_rocketmq_send(data); }