| | |
|---|
| | | /*
|
|---|
| | | 发布消息，data 是 MsgPublish protobuffer序列化后的数据
|
|---|
| | | */
|
|---|
| | | int bus_client_pubmsg(void* handle, const char* data, const size_t size);
|
|---|
| | | int bus_client_publish_msg(void* handle, const char* data, const size_t size);
|
|---|
| | | /*
|
|---|
| | | 发布消息，topic 是发布主题， data 是发布的消息体
|
|---|
| | | */
|
|---|
| | |
|---|
| | | 通过 message.h 的 make_reply_msg 创建时，有内存拷贝，必须通过 free_reply_msg 释放
|
|---|
| | | 或者通过填充 crepmsg 结构体构造，由调用者控制变量的内存和生命周期，可能不会拷贝内存，效率更高
|
|---|
| | | */
|
|---|
| | | int bus_client_reply_msg(void* handle, void* src, const struct crepmsg* msg);
|
|---|
| | | int bus_client_reply(void* handle, void* src, const struct crepmsg* msg);
|
|---|
| | | /*
|
|---|
| | | 同步的request请求，发送 creqmsg 获取 crepmsg 回复
|
|---|
| | | 通过 message.h 的 make_req_msg 创建 request 消息时，必须调用 free_reqmsg 释放
|
|---|
