zmq::recv_multipart #645

Merged
pavel.baykov merged 2 commits from bug/issue111 into develop 2022-02-16 18:25:26 +00:00
Showing only changes of commit 7dca93071d - Show all commits

View file

@ -872,8 +872,11 @@ std::vector<zmq::message_t> zmq_listener::receive_multipart() {
std::vector<zmq::message_t> msgs;
auto res = zmq::recv_multipart(socket, std::back_inserter(msgs));
assert(res);
assert(3 == *res);
FC_ASSERT(res);
if (3 != *res) {
elog("zmq::recv_multipart returned: ${res}", ("res", *res));
throw zmq::error_t();
}
return msgs;
}