diff --git a/core-writer/include/ZmqRecvModule.hpp b/core-writer/include/ZmqRecvModule.hpp
index c65005b..348b821 100644
--- a/core-writer/include/ZmqRecvModule.hpp
+++ b/core-writer/include/ZmqRecvModule.hpp
@@ -25,9 +25,11 @@ public:
             const header_map& header_values,
             const std::atomic_bool& is_writing);
 
-    void start(const std::string& connect_address,
+    void start_recv(const std::string& connect_address,
                const uint8_t n_receiving_threads);
-    void stop();
+    void stop_recv();
+
+
 };
 
 #endif
\ No newline at end of file
diff --git a/core-writer/src/ZmqRecvModule.cpp b/core-writer/src/ZmqRecvModule.cpp
index 38dd787..27be1b1 100644
--- a/core-writer/src/ZmqRecvModule.cpp
+++ b/core-writer/src/ZmqRecvModule.cpp
@@ -16,7 +16,7 @@ ZmqRecvModule::ZmqRecvModule(
             is_receiving_(false)
 {}
 
-void ZmqRecvModule::start(
+void ZmqRecvModule::start_recv(
         const string& connect_address,
         const uint8_t n_receiving_threads)
 {
@@ -50,7 +50,7 @@ void ZmqRecvModule::start(
     }
 }
 
-void ZmqRecvModule::stop()
+void ZmqRecvModule::stop_recv()
 {
     #ifdef DEBUG_OUTPUT
         using namespace date;