From b75596e8a08586761d330bd808941591788a01d9 Mon Sep 17 00:00:00 2001
From: Andrej Babic <andrej.babic@psi.ch>
Date: Wed, 8 Apr 2020 16:42:42 +0200
Subject: [PATCH] Add destructor to Recv Module

---
 core-writer/include/ZmqRecvModule.hpp    | 2 ++
 core-writer/src/module/ZmqRecvModule.cpp | 5 +++++
 2 files changed, 7 insertions(+)

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)