src/msg.h
@@ -59,7 +59,9 @@ int num_ = 1; }; BHMsg MakeQueryTopic(const std::string &topic); BHMsg MakeRequest(const MQId &src_id, const void *data, const size_t size); BHMsg MakeRequest(const MQId &src_id, const std::string &topic, const void *data, const size_t size); BHMsg MakeReply(const void *data, const size_t size); BHMsg MakeSub(const MQId &client, const std::vector<std::string> &topics); BHMsg MakeUnsub(const MQId &client, const std::vector<std::string> &topics);