diff --git a/core-writer/src/ProcessManager.cpp b/core-writer/src/ProcessManager.cpp
index 5c025f5..13bd23c 100644
--- a/core-writer/src/ProcessManager.cpp
+++ b/core-writer/src/ProcessManager.cpp
@@ -52,67 +52,3 @@ void ProcessManager::run_receivers(uint8_t n_receiving_threads)
         cout << "[ProcessManager::run_writer] Writer properly stopped." << endl;
     #endif
 }
-
-void ProcessManager::receive_zmq()
-{
-    receiver.connect();
-
-    while (writer_manager.is_running()) {
-        
-        auto frame = receiver.receive();
-        
-        // In case no message is available before the timeout, both pointers are NULL.
-        if (!frame.first || !writer_manager.receive_frame()){
-            continue;
-        }
-
-        auto frame_metadata = frame.first;
-        auto frame_data = frame.second;
-
-        #ifdef DEBUG_OUTPUT
-            using namespace date;
-            cout << "[" << std::chrono::system_clock::now() << "]";
-            cout << "[ProcessManager::receive_zmq] Processing FrameMetadata"; 
-            cout << " with frame_index " << frame_metadata->frame_index;
-            cout << " and frame_shape [" << frame_metadata->frame_shape[0] << ", " << frame_metadata->frame_shape[1] << "]";
-            cout << " and endianness " << frame_metadata->endianness;
-            cout << " and type " << frame_metadata->type;
-            cout << " and frame_bytes_size " << frame_metadata->frame_bytes_size;
-            cout << "." << endl;
-        #endif
-
-        char* buffer = ring_buffer.reserve(frame_metadata);
-
-        size_t max_buffer_size = compression::get_bitshuffle_max_buffer_size(
-            frame_metadata->frame_bytes_size, 1);
-
-        if (max_buffer_size > ring_buffer.get_slot_size()) {
-             
-        }
-    
-        auto compressed_size = compression::compress_bitshuffle(
-            static_cast<const char*>(frame_data),
-            frame_metadata->frame_bytes_size,
-            1,
-            buffer);
-
-        #ifdef DEBUG_OUTPUT
-            using namespace date;
-            cout << "[" << std::chrono::system_clock::now() << "]";
-            cout << "[ProcessManager::receive_zmq] Compressed image from "; 
-            cout << frame_metadata->frame_bytes_size << " bytes to "; 
-            cout << compressed_size << " bytes." << endl; 
-        #endif
-
-        frame_metadata->frame_bytes_size = compressed_size;
-
-        ring_buffer.commit(frame_metadata);
-   }
-
-    #ifdef DEBUG_OUTPUT
-        using namespace date;
-        cout << "[" << std::chrono::system_clock::now() << "]";
-        cout << "[ProcessManager::receive_zmq] Receiver thread stopped." << endl;
-    #endif
-}
-
diff --git a/core-writer/src/WriterManager.cpp b/core-writer/src/WriterManager.cpp
index 1afc1c2..f910803 100644
--- a/core-writer/src/WriterManager.cpp
+++ b/core-writer/src/WriterManager.cpp
@@ -411,73 +411,3 @@ void WriterManager::write_h5(const string output_file, const uint64_t n_frames)
         writing_error(ex.what());
     }
 }
-
-void WriterManager::receive_zmq()
-{
-    receiver.connect();
-
-    while (is_running()) {
-        
-        auto frame = receiver.receive();
-        
-        // If receive timeout, both pointers are NULL.
-        if (!frame.first || !receive_frame()){
-            continue;
-        }
-
-        auto frame_metadata = frame.first;
-        auto frame_data = frame.second;
-
-        #ifdef DEBUG_OUTPUT
-            using namespace date;
-            using namespace chrono;
-            cout << "[" << system_clock::now() << "]";
-            cout << "[ProcessManager::receive_zmq]";
-            cout << " Processing FrameMetadata";
-            cout << " with frame_index " << frame_metadata->frame_index;
-            cout << " and frame_shape [" << frame_metadata->frame_shape[0];
-            cout << ", " << frame_metadata->frame_shape[1] << "]";
-            cout << " and endianness " << frame_metadata->endianness;
-            cout << " and type " << frame_metadata->type;
-            cout << " and frame_bytes_size "; 
-            cout << frame_metadata->frame_bytes_size << "." << endl;
-        #endif
-
-        char* buffer = ring_buffer.reserve(frame_metadata);
-
-        size_t max_buffer_size = compression::get_bitshuffle_max_buffer_size(
-            frame_metadata->frame_bytes_size, 1);
-
-        if (max_buffer_size > ring_buffer.get_slot_size()) {
-             
-        }
-    
-        auto compressed_size = compression::compress_bitshuffle(
-            static_cast<const char*>(frame_data),
-            frame_metadata->frame_bytes_size,
-            1,
-            buffer);
-
-        #ifdef DEBUG_OUTPUT
-            using namespace date;
-            using namespace chrono;
-            cout << "[" << system_clock::now() << "]";
-            cout << "[WriterManager::receive_zmq]";
-            cout << " Compressed image from ";
-            cout << frame_metadata->frame_bytes_size << " bytes to "; 
-            cout << compressed_size << " bytes." << endl; 
-        #endif
-
-        frame_metadata->frame_bytes_size = compressed_size;
-
-        ring_buffer.commit(frame_metadata);
-   }
-
-    #ifdef DEBUG_OUTPUT
-        using namespace date;
-        using namespace chrono;
-        cout << "[" << system_clock::now() << "]";
-        cout << "[WriterManager::receive_zmq]";
-        cout << " Receiver thread stopped." << endl;
-    #endif
-}