From 35cc4cf70e664a4c0a46ddf674ef1d30b364ef8e Mon Sep 17 00:00:00 2001 From: Andrej Babic Date: Wed, 15 Apr 2020 10:42:58 +0200 Subject: [PATCH] Change ZMQ mode back to PULL --- core-writer/src/receiver/ZmqReceiver.cpp | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/core-writer/src/receiver/ZmqReceiver.cpp b/core-writer/src/receiver/ZmqReceiver.cpp index 8f80c69..344f3e1 100644 --- a/core-writer/src/receiver/ZmqReceiver.cpp +++ b/core-writer/src/receiver/ZmqReceiver.cpp @@ -56,7 +56,7 @@ ZmqReceiver::ZmqReceiver( const int n_io_threads) : header_values_type_(header_values_type), context_(n_io_threads), - socket_(context_, ZMQ_SUB), + socket_(context_, ZMQ_PULL), message_header_(config::zmq_buffer_size_header), message_data_(config::zmq_buffer_size_data) { @@ -118,6 +118,7 @@ pair, char*> ZmqReceiver::receive() // Get the message header. auto recv_n_bytes_header = socket_.recv(message_header_); + if (!recv_n_bytes_header.has_value()){ return {nullptr, nullptr}; }