diff --git a/core-writer/include/ZmqRecvModule.hpp b/core-writer/include/ZmqRecvModule.hpp
index 6355516..36f1b64 100644
--- a/core-writer/include/ZmqRecvModule.hpp
+++ b/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();
diff --git a/core-writer/src/module/ZmqRecvModule.cpp b/core-writer/src/module/ZmqRecvModule.cpp
index 11491a9..ff3030a 100644
--- a/core-writer/src/module/ZmqRecvModule.cpp
+++ b/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)