| | |
| | | |
| | | BHOME_SIMPLE_MAP_MSG(CommonReply); |
| | | BHOME_SIMPLE_MAP_MSG(Register); |
| | | BHOME_SIMPLE_MAP_MSG(Unregister); |
| | | BHOME_SIMPLE_MAP_MSG(RegisterRPC); |
| | | BHOME_SIMPLE_MAP_MSG(Heartbeat); |
| | | BHOME_SIMPLE_MAP_MSG(QueryTopic); |
| | |
| | | return msg; |
| | | } |
| | | std::string NewMsgId(); |
| | | BHMsgHead InitMsgHead(const MsgType type, const std::string &proc_id, const std::string &msgid); |
| | | BHMsgHead InitMsgHead(const MsgType type, const std::string &proc_id); |
| | | BHMsgHead InitMsgHead(const MsgType type, const std::string &proc_id, const uint64_t ssn_id, const std::string &msgid); |
| | | BHMsgHead InitMsgHead(const MsgType type, const std::string &proc_id, const uint64_t ssn_id); |
| | | // inline void AddRoute(BHMsgHead &head, const MQId &id) { head.add_route()->set_mq_id(&id, sizeof(id)); } |
| | | inline bool IsSuccess(const ErrorCode ec) { return ec == eSuccess; } |
| | | bool IsMsgExpired(const BHMsgHead &head); |