From d26327b3cde043a9470dcd7fea8e704ea517fdae Mon Sep 17 00:00:00 2001 From: lichao <lichao@aiotlink.com> Date: 星期四, 01 四月 2021 19:26:57 +0800 Subject: [PATCH] add req/rep center; --- src/msg.h | 8 +++++--- 1 files changed, 5 insertions(+), 3 deletions(-) diff --git a/src/msg.h b/src/msg.h index ea1e636..8c345fd 100644 --- a/src/msg.h +++ b/src/msg.h @@ -59,10 +59,12 @@ int num_ = 1; }; -BHMsg MakeQueryTopic(const std::string &topic); -BHMsg MakeRequest(const MQId &src_id, const void *data, const size_t size); +BHMsg MakeQueryTopic(const MQId &client, const std::string &topic); +BHMsg MakeQueryTopicReply(const std::string &mqid, const std::string &msgid); 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 MakeReply(const std::string &src_msgid, const void *data, const size_t size); +BHMsg MakeRegister(const MQId &src_id, ProcInfo info, const std::vector<std::string> &topics); +BHMsg MakeHeartbeat(const MQId &src_id, ProcInfo info); BHMsg MakeSub(const MQId &client, const std::vector<std::string> &topics); BHMsg MakeUnsub(const MQId &client, const std::vector<std::string> &topics); BHMsg MakePub(const std::string &topic, const void *data, const size_t size); -- Gitblit v1.8.0