Browse Source

#分布式客户端修改

zxs 2 weeks ago
parent
commit
cb845be021
1 changed files with 8 additions and 1 deletions
  1. 8 1
      robot/robotics/nexus_net_client.hpp

+ 8 - 1
robot/robotics/nexus_net_client.hpp

@@ -104,6 +104,10 @@ namespace robotics {
              * @brief 订阅
              */
             SUBSCRIBE,
+            /**
+             * @brief 订阅响应
+             */
+            REPSUBSCRIBE,
             /**
              * @brief 删除订阅
              */
@@ -471,6 +475,7 @@ namespace robotics {
                     {(std::uint8_t)nexus_net_msg_type_enum::AUTHENTICATE,     "身份认证"},
                     {(std::uint8_t)nexus_net_msg_type_enum::REPAUTHENTICATE,  "身份认证响应"},
                     {(std::uint8_t)nexus_net_msg_type_enum::SUBSCRIBE,        "订阅"},
+                    {(std::uint8_t)nexus_net_msg_type_enum::REPSUBSCRIBE,     "订阅响应"},
                     {(std::uint8_t)nexus_net_msg_type_enum::REMOVESUBSCRIBE,  "删除订阅"},
                     {(std::uint8_t)nexus_net_msg_type_enum::PUBLISHER,        "发布"},
                     {(std::uint8_t)nexus_net_msg_type_enum::REPPUBLISHER,     "发布响应"},
@@ -888,7 +893,9 @@ namespace robotics {
              * @param data
              */
             void on_authenticate(nexus_net_message data) {
-                data.args >> is_heartbeat_ >> parent_code_ >> parent_name_;
+                std::string node_name;
+                std::string message;
+                data.args >> is_heartbeat_ >> parent_code_ >> parent_name_ >> node_name >> message;
                 if (is_heartbeat_) {
                     authorized_event(true, parent_code_, parent_name_);
                     subscribe();