diff options
| -rw-r--r-- | src/InputZeroMQReader.cpp | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/src/InputZeroMQReader.cpp b/src/InputZeroMQReader.cpp index 4b55434..afb6b7d 100644 --- a/src/InputZeroMQReader.cpp +++ b/src/InputZeroMQReader.cpp @@ -147,6 +147,7 @@ void InputZeroMQWorker::Start(struct InputZeroMQThreadData* workerdata) void InputZeroMQWorker::Stop() { running = false; + zmqcontext.close(); recv_thread.join(); } |