From ba9e213d3f01555d823aaf453798a148dade45a4 Mon Sep 17 00:00:00 2001 From: zhangmeng <775834166@qq.com> Date: 星期二, 13 十二月 2022 09:56:18 +0800 Subject: [PATCH] 添加注释 --- main.cpp | 15 ++++++++------- 1 files changed, 8 insertions(+), 7 deletions(-) diff --git a/main.cpp b/main.cpp index 1e57df9..6d0e4bd 100644 --- a/main.cpp +++ b/main.cpp @@ -46,13 +46,14 @@ while (true) { for(auto && i : topics){ auto msg = base_msg + "test_ps pub message "+i+"-->msg-"+to_string(count++); - MsgPublish pbmsg; - pbmsg.set_topic(i); - pbmsg.set_data(msg); - auto data = pbmsg.SerializeAsString(); - // TestPub(i.c_str(), i.length(), data.c_str(), data.length()); - int pubres = bus_client_pubmsg(handle, (void*)data.data(), data.size()); - printf("======>> bus_client_pubmsg [%s]\n", msg.c_str()); + // MsgPublish pbmsg; + // pbmsg.set_topic(i); + // pbmsg.set_data(msg); + // auto data = pbmsg.SerializeAsString(); + // int ret = bus_client_pubmsg(handle, data.data(), data.size()); + + int ret = bus_client_publish(handle, i.data(), i.size(), msg.data(), msg.size()); + printf("======>> bus_client_pubmsg [%s] ret %d\n", msg.c_str(), ret); this_thread::sleep_for(chrono::seconds{2}); } } -- Gitblit v1.8.0