Change ZMQ to SUB

2026-05-01 23:02:21 +02:00 · 2020-04-09 13:37:51 +02:00
parent 053f714eb7
commit 86b452312e
1 changed files with 1 additions and 1 deletions
@@ -56,7 +56,7 @@ ZmqReceiver::ZmqReceiver(
        const int n_io_threads) :
            header_values_type_(header_values_type),
            context_(n_io_threads),
-            socket_(context_, ZMQ_PULL),
+            socket_(context_, ZMQ_SUB),
            message_header_(config::zmq_buffer_size_header),
            message_data_(config::zmq_buffer_size_data)
 {