@@ -611,12 +611,12 @@ bool V2VCommManager::setupCommonTopics(uint8_t platoonId, uint8_t vehicleId)
611611 /* Subscribe to Input Topic. */
612612 if (false == m_mqttClient.subscribe (m_waypointInputTopic, false , lambdaWaypointInputTopicCallback))
613613 {
614- LOG_ERROR (" Could not subcribe to MQTT Topic: %s." , m_waypointInputTopic.c_str ());
614+ LOG_ERROR (" Could not subscribe to MQTT Topic: %s." , m_waypointInputTopic.c_str ());
615615 }
616616 /* Subscribe to emergency topic. */
617617 else if (false == m_mqttClient.subscribe (m_emergencyTopic, false , lambdaWaypointInputTopicCallback))
618618 {
619- LOG_ERROR (" Could not subcribe to MQTT Topic: %s." , m_emergencyTopic);
619+ LOG_ERROR (" Could not subscribe to MQTT Topic: %s." , m_emergencyTopic);
620620 }
621621 else
622622 {
@@ -667,7 +667,7 @@ bool V2VCommManager::setupHeartbeatTopics(uint8_t platoonId, uint8_t vehicleId)
667667 /* Subscribe to platoon heartbeat Topic. */
668668 if (false == m_mqttClient.subscribe (m_platoonHeartbeatTopic, false , lambdaHeartbeatInputTopicCallback))
669669 {
670- LOG_ERROR (" Could not subcribe to MQTT Topic: %s." , m_platoonHeartbeatTopic.c_str ());
670+ LOG_ERROR (" Could not subscribe to MQTT Topic: %s." , m_platoonHeartbeatTopic.c_str ());
671671 }
672672 {
673673 isSuccessful = true ;
@@ -700,17 +700,17 @@ bool V2VCommManager::setupLeaderTopics()
700700 /* Subscribe to Vehicles Heartbeat Topics. */
701701 else if (false == m_mqttClient.subscribe (m_heartbeatResponseTopic, false , lambdaEventCallback))
702702 {
703- LOG_ERROR (" Could not subcribe to MQTT Topic: %s." , m_platoonHeartbeatTopic.c_str ());
703+ LOG_ERROR (" Could not subscribe to MQTT Topic: %s." , m_platoonHeartbeatTopic.c_str ());
704704 }
705705 /* Subscribe to Last Vehicle Feedback Topic. */
706706 else if (false == m_mqttClient.subscribe (m_feedbackTopic, false , lambdaEventCallback))
707707 {
708- LOG_ERROR (" Could not subcribe to MQTT Topic: %s." , m_feedbackTopic.c_str ());
708+ LOG_ERROR (" Could not subscribe to MQTT Topic: %s." , m_feedbackTopic.c_str ());
709709 }
710710 /* Subscribe to IVS Topic. */
711711 else if (false == m_mqttClient.subscribe (m_ivsTopic, false , lambdaEventCallback))
712712 {
713- LOG_ERROR (" Could not subcribe to MQTT Topic: %s." , m_ivsTopic.c_str ());
713+ LOG_ERROR (" Could not subscribe to MQTT Topic: %s." , m_ivsTopic.c_str ());
714714 }
715715 else
716716 {
@@ -867,4 +867,4 @@ bool V2VCommManager::sendPlatoonLength(const int32_t length) const
867867
868868/* *****************************************************************************
869869 * Local Functions
870- *****************************************************************************/
870+ *****************************************************************************/
0 commit comments