diff --git a/lib/src/ZmqReceiver.cpp b/lib/src/ZmqReceiver.cpp
index f344555..0c7a8b8 100644
--- a/lib/src/ZmqReceiver.cpp
+++ b/lib/src/ZmqReceiver.cpp
@@ -62,6 +62,27 @@ ZmqReceiver::ZmqReceiver(const std::string& connect_address, const int n_io_thre
     message_data = zmq::message_t(config::zmq_buffer_size_data);
 }
 
+
+ZmqReceiver::ZmqReceiver(const ZmqReceiver& other) :
+    connect_address(other.connect_address), n_io_threads(other.n_io_threads), 
+    receive_timeout(other.receive_timeout), receiver(NULL), header_values_type(other.header_values_type)
+{
+    
+    #ifdef DEBUG_OUTPUT
+        using namespace date;
+        cout << "[" << std::chrono::system_clock::now() << "]";
+        cout << "[ZmqReceiver::ZmqReceiver] Creating ZMQ receiver with";
+        cout << " connect_address " << connect_address;
+        cout << " n_io_threads " << n_io_threads;
+        cout << " receive_timeout " << receive_timeout;
+        cout << endl;
+    #endif
+
+    message_header = zmq::message_t(config::zmq_buffer_size_header);
+    message_data = zmq::message_t(config::zmq_buffer_size_data);
+}
+
+
 void ZmqReceiver::connect()
 {
     #ifdef DEBUG_OUTPUT
diff --git a/lib/src/ZmqReceiver.hpp b/lib/src/ZmqReceiver.hpp
index 8e2de71..8b1937f 100644
--- a/lib/src/ZmqReceiver.hpp
+++ b/lib/src/ZmqReceiver.hpp
@@ -51,6 +51,8 @@ class ZmqReceiver
         ZmqReceiver(const std::string& connect_address, const int n_io_threads, const int receive_timeout,
             std::shared_ptr<std::unordered_map<std::string, HeaderDataType>> header_values_type=NULL);
 
+        ZmqReceiver(const ZmqReceiver& other);
+
         virtual ~ZmqReceiver(){};
 
         void connect();
@@ -63,4 +65,4 @@ class ZmqReceiver
 
 };
 
-#endif
\ No newline at end of file
+#endif