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