Add destructor to Recv Module

core-writer/include/ZmqRecvModule.hpp

@@ -24,6 +24,8 @@ public:
             RingBuffer& ring_buffer,
             const header_map& header_values);
 
+    virtual ~ZmqRecvModule();
+
     void start_recv(const std::string& connect_address,
                const uint8_t n_receiving_threads);
     void stop_recv();

core-writer/src/module/ZmqRecvModule.cpp

@@ -15,6 +15,11 @@ ZmqRecvModule::ZmqRecvModule(
             is_saving_(false)
 {}
 
+ZmqRecvModule::~ZmqRecvModule()
+{
+    stop_recv();
+}
+
 void ZmqRecvModule::start_recv(
         const string& connect_address,
         const uint8_t n_receiving_threads)