diff --git a/core-writer/src/module/ZmqRecvModule.cpp b/core-writer/src/module/ZmqRecvModule.cpp index 600dcb1..9738cfa 100644 --- a/core-writer/src/module/ZmqRecvModule.cpp +++ b/core-writer/src/module/ZmqRecvModule.cpp @@ -128,7 +128,7 @@ void ZmqRecvModule::receive_thread(const string& connect_address) continue; } - if (!is_saving_.load(memory_order_relaxed)) { + if (!is_saving_) { continue; }