From 1949eab3efb40c93c990eaf42a7930238f13149a Mon Sep 17 00:00:00 2001 From: Andrej Babic Date: Fri, 3 Apr 2020 13:51:35 +0200 Subject: [PATCH] Substitute deprecated method with valid one for Zmq recv --- core-writer/src/receiver/ZmqReceiver.cpp | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/core-writer/src/receiver/ZmqReceiver.cpp b/core-writer/src/receiver/ZmqReceiver.cpp index 356464c..226fd07 100644 --- a/core-writer/src/receiver/ZmqReceiver.cpp +++ b/core-writer/src/receiver/ZmqReceiver.cpp @@ -117,17 +117,17 @@ pair, char*> ZmqReceiver::receive() } // Get the message header. - if (!socket_.recv(&message_header_)){ + if (!socket_.recv(message_header_)){ return {nullptr, nullptr}; } auto header_string = string( - static_cast(message_header.data()), - message_header.size()); + static_cast(message_header_.data()), + message_header_.size()); auto frame_metadata = read_json_header(header_string); // Get the message data. - if (!socket_.recv(&message_data)) { + if (!socket_.recv(message_data_)) { using namespace date; using namespace chrono; cout << "[" << system_clock::now() << "]"; @@ -139,9 +139,9 @@ pair, char*> ZmqReceiver::receive() return {nullptr, nullptr}; } - frame_metadata->frame_bytes_size = message_data.size(); + frame_metadata->frame_bytes_size = message_data_.size(); - return {frame_metadata, static_cast(message_data.data())}; + return {frame_metadata, static_cast(message_data_.data())}; } shared_ptr ZmqReceiver::read_json_header(const string& header)