Merge branch '230308-repub-fix' into 'main'

ZMQImagePuller: Fix republish socket direction See merge request jungfraujoch/nextgendcu!32
2024-03-08 09:40:03 +01:00
parent 7a12617517 19dbbdd8bb
commit 738cd26e6b
1 changed files with 1 additions and 1 deletions
@@ -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<ZMQSocket>(context, ZMQSocketType::Pull);
+        repub_socket = std::make_unique<ZMQSocket>(context, ZMQSocketType::Push);
        repub_socket->SendWaterMark(100);
        repub_socket->SendTimeout(std::chrono::milliseconds(100));
        repub_socket->Bind(repub_address);