diff --git a/writer/ZMQImagePuller.cpp b/writer/ZMQImagePuller.cpp index 9f43f31d..b03c2c9e 100644 --- a/writer/ZMQImagePuller.cpp +++ b/writer/ZMQImagePuller.cpp @@ -10,7 +10,7 @@ ZMQImagePuller::ZMQImagePuller(ZMQContext &context, const std::string &repub_add zmq_recv_buffer.reserve(2*1024*1024); // Reasonable size 2 MiB if (!repub_address.empty()) { - repub_socket = std::make_unique(context, ZMQSocketType::Pull); + repub_socket = std::make_unique(context, ZMQSocketType::Push); repub_socket->SendWaterMark(100); repub_socket->SendTimeout(std::chrono::milliseconds(100)); repub_socket->Bind(repub_address);