diff --git a/topic_tools/src/mux_node.cpp b/topic_tools/src/mux_node.cpp index 292161d..5968ecc 100644 --- a/topic_tools/src/mux_node.cpp +++ b/topic_tools/src/mux_node.cpp @@ -64,6 +64,10 @@ void MuxNode::make_subscribe_unsubscribe_decisions() void MuxNode::process_message(std::shared_ptr msg) { + std::scoped_lock lock(pub_mutex_); + if (!pub_) { + return; + } pub_->publish(*msg); }