diff --git a/core-buffer/include/LiveRecvModule.hpp b/core-buffer/include/LiveRecvModule.hpp
index 27b72c0..d63357a 100644
--- a/core-buffer/include/LiveRecvModule.hpp
+++ b/core-buffer/include/LiveRecvModule.hpp
@@ -31,6 +31,8 @@ public:
             ModuleFrameBuffer *metadata,
             char *data);
 
+    void stop();
+
 };
 
 
diff --git a/core-buffer/src/LiveRecvModule.cpp b/core-buffer/src/LiveRecvModule.cpp
index 082ca85..691222c 100644
--- a/core-buffer/src/LiveRecvModule.cpp
+++ b/core-buffer/src/LiveRecvModule.cpp
@@ -32,6 +32,11 @@ LiveRecvModule::LiveRecvModule(
 }
 
 LiveRecvModule::~LiveRecvModule()
+{
+    stop();
+}
+
+void LiveRecvModule::stop()
 {
     is_receiving_ = false;
     receiving_thread_.join();