Add is_receiving function to ZmqRecvModule

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();

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