From 1107a08d0fbf6ecd4a3c4da2e565087c59c5f08f Mon Sep 17 00:00:00 2001
From: Andrej Babic <andrej.babic@psi.ch>
Date: Fri, 3 Apr 2020 13:48:10 +0200
Subject: [PATCH] Adjust usage of new ZmqReceiver

---
 core-writer/src/ZmqRecvModule.cpp | 9 ++-------
 1 file changed, 2 insertions(+), 7 deletions(-)

diff --git a/core-writer/src/ZmqRecvModule.cpp b/core-writer/src/ZmqRecvModule.cpp
index 29a0c2d..5df0e10 100644
--- a/core-writer/src/ZmqRecvModule.cpp
+++ b/core-writer/src/ZmqRecvModule.cpp
@@ -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)) {