diff --git a/com/mqtt_callback.cpp b/com/mqtt_callback.cpp index 7b8e0f2..e5bf3d6 100644 --- a/com/mqtt_callback.cpp +++ b/com/mqtt_callback.cpp @@ -40,7 +40,11 @@ void mqtt_callback::message_arrived(mqtt::const_message_ptr msg) { } else if (!intMsg[mem_->comSettings.NODE].compare(mem_->comSettings.nodeNames["recorder"])) { mem_->commonStatus.recorderRunning = true; mem_->commonStatus.recorderLast = std::stod(intMsg[mem_->comSettings.TS]); - log_->trace("HB RECORDER time: [{}]", mem_->commonStatus.recorderLast); + log_->trace("HB RECORDER time: [{}]", mem_->commonStatus.recorderLast); + } else if (!intMsg[mem_->comSettings.NODE].compare(mem_->comSettings.nodeNames["broadcaster"])) { + mem_->commonStatus.broadcasterRunning = true; + mem_->commonStatus.broadcasterLast = std::stod(intMsg[mem_->comSettings.TS]); + log_->trace("HB BROADCASTER time: [{}]", mem_->commonStatus.broadcasterLast); } else { log_->error("Node {} unknown", intMsg[mem_->comSettings.NODE].c_str()); } @@ -53,7 +57,7 @@ void mqtt_callback::message_arrived(mqtt::const_message_ptr msg) { } else if (msg->get_topic() == mem_->comSettings.subMap.find("coordinates")->second){ log_->debug("MQTT: Coordinate Message: {}", msg->get_payload().c_str()); } else { - log_->error("Unrecognized topic"); + log_->error("Unrecognized topic: {}", msg->get_topic().c_str()); } } diff --git a/shared/roboglue_shared.h b/shared/roboglue_shared.h index e1e86a4..55b9f53 100644 --- a/shared/roboglue_shared.h +++ b/shared/roboglue_shared.h @@ -56,6 +56,7 @@ public: bool relayRunning = false; bool followerRunning = false; bool recorderRunning = false; + bool broadcasterRunning = false; // ROS node last seen double relayLast = static_cast(time(NULL)); double followerLast = static_cast(time(NULL));