| | |
| | | reply_head.mutable_proc_id()->swap(out_proc_id); |
| | | return true; |
| | | } |
| | | } catch (...) { |
| | | } catch (std::exception &e) { |
| | | LOG_ERROR() << __func__ << " exception: " << e.what(); |
| | | SetLastError(eError, __func__ + std::string(" internal errer.")); |
| | | } |
| | | return false; |
| | |
| | | reply.ParseBody(reply_body) && |
| | | IsSuccess(reply_body.errmsg().errcode()); |
| | | } |
| | | // TODO wait for result? |
| | | } catch (...) { |
| | | return false; |
| | | } |
| | |
| | | return false; |
| | | } |
| | | } |
| | | //TODO error msg. |
| | | if (head.type() == kMsgTypePublish) { |
| | | if (pub.ParseFromString(body)) { |
| | | head.mutable_proc_id()->swap(proc_id); |
| | | return true; |
| | | } |
| | | } |
| | | SetLastError(eError, "invalid subcribe msg received."); |
| | | return false; |
| | | } |