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