| | |
| | | return false;
|
| | | }
|
| | |
|
| | | 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){
|
| | |
|
| | | MsgRequestTopicReply msgR;
|
| | | auto err = msgR.mutable_errmsg();
|
| | |
| | | pbmsg.set_topic(topic, topicl);
|
| | | pbmsg.set_data(data, size);
|
| | | auto pbstr = pbmsg.SerializeAsString();
|
| | | return bus_client_pubmsg(handle, pbstr.data(), pbstr.size());
|
| | | return bus_client_publish_msg(handle, pbstr.data(), pbstr.size());
|
| | | }
|
| | |
|
| | | // test
|
| | | 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){
|
| | | client* cli = ptr(handle);
|
| | | return bus_publish(cli->bus, data, size, 100);
|
| | | }
|