Adjust usage of new ZmqReceiver

2026-04-30 22:02:22 +02:00 · 2020-04-03 13:48:10 +02:00
parent 3853e08238
commit 1107a08d0f
1 changed files with 2 additions and 7 deletions
@@ -98,13 +98,8 @@ void ZmqRecvModule::stop_writing()

 void ZmqRecvModule::receive_thread(const string& connect_address)
 {
-    ZmqReceiver receiver(
-            connect_address,
-            config::zmq_n_io_threads,
-            config::zmq_receive_timeout,
-            header_values_);
-
-    receiver.connect();
+    ZmqReceiver receiver(header_values_);
+    receiver.connect(connect_address);

    while (is_receiving_.load(memory_order_relaxed)) {