diff --git a/core-writer/include/ZmqRecvModule.hpp b/core-writer/include/ZmqRecvModule.hpp
index 7f861b7..6355516 100644
--- a/core-writer/include/ZmqRecvModule.hpp
+++ b/core-writer/include/ZmqRecvModule.hpp
@@ -27,6 +27,7 @@ public:
     void start_recv(const std::string& connect_address,
                const uint8_t n_receiving_threads);
     void stop_recv();
+    bool is_receiving();
 
     void start_saving();
     void stop_saving_and_clear_buffer();
diff --git a/core-writer/src/module/ZmqRecvModule.cpp b/core-writer/src/module/ZmqRecvModule.cpp
index 1bcb143..11491a9 100644
--- a/core-writer/src/module/ZmqRecvModule.cpp
+++ b/core-writer/src/module/ZmqRecvModule.cpp
@@ -84,6 +84,11 @@ void ZmqRecvModule::stop_recv()
     receiving_threads_.clear();
 }
 
+bool ZmqRecvModule::is_receiving()
+{
+    return is_receiving_;
+}
+
 void ZmqRecvModule::start_saving()
 {
     #ifdef DEBUG_OUTPUT