| | |
| | | req_body.set_topic("topic"); |
| | | req_body.set_data(msg_content); |
| | | auto req_head(InitMsgHead(GetType(req_body), client_proc_id)); |
| | | return cli.Send(&srv.id(), req_head, req_body, 100); |
| | | return cli.Send(&srv.id(), req_head, req_body); |
| | | }; |
| | | auto ReqRC = [&]() { return cli.Send(&srv.id(), request_rc, 1000); }; |
| | | auto ReqRC = [&]() { return cli.Send(&srv.id(), request_rc); }; |
| | | |
| | | if (!ReqRC()) { |
| | | printf("********** client send error.\n"); |
| | |
| | | reply_body.set_topic("topic"); |
| | | reply_body.set_data(msg_content); |
| | | auto reply_head(InitMsgHead(GetType(reply_body), server_proc_id, req_head.msg_id())); |
| | | return srv.Send(&src_id, reply_head, reply_body, 100); |
| | | return srv.Send(&src_id, reply_head, reply_body); |
| | | }; |
| | | auto ReplyRC = [&]() { return srv.Send(&src_id, reply_rc, 100); }; |
| | | auto ReplyRC = [&]() { return srv.Send(&src_id, reply_rc); }; |
| | | |
| | | if (ReplyRC()) { |
| | | } |