mqtt: {} for LOG_x

Author: viacheslauK

mqtt_streaming_client_module/src/mqtt_base_fb.cpp

@@ -52,7 +52,9 @@ void MqttBaseFb::subscribeToTopics()
         bool success = true;
         auto lambda = [this](const mqtt::MqttAsyncClient &client, mqtt::MqttMessage &msg){this->onSignalsMessage(client, msg);};
         if (!getSubscribedTopics().empty())
+        {
             LOG_I("Trying to subscribe to the topics");
+        }
         for (const auto& topic : getSubscribedTopics())
         {
             subscriber->setMessageArrivedCb(topic, lambda);

mqtt_streaming_client_module/src/mqtt_json_receiver_fb_impl.cpp

@@ -81,7 +81,9 @@ void MqttJsonReceiverFbImpl::createSignals()
 {
     auto lock = std::scoped_lock<std::mutex>(sync);
     if (!subscribedSignals.empty())
+    {
         LOG_I("Creating signals...");
+    }
 
     for (const auto& signalId : signalIdList)
     {

mqtt_streaming_client_module/src/mqtt_raw_receiver_fb_impl.cpp

@@ -43,7 +43,9 @@ void MqttRawReceiverFbImpl::readProperties()
         {
             isPresent = true;
             if (prop.getCount() != 0)
+            {
                 LOG_I("Topics in the list:");
+            }
             for (const auto& topic : prop)
             {
                 auto topicStr = topic.asPtr<IString>();
@@ -86,7 +88,9 @@ void MqttRawReceiverFbImpl::createSignals()
 {
     auto lock = std::scoped_lock<std::mutex>(sync);
     if (!topicsForSubscribing.empty())
+    {
         LOG_I("Creating signals...");
+    }
     for (const auto& topic : topicsForSubscribing)
     {
         LOG_D("\tfor the topic: {}", topic);

mqtt_streaming_protocol/src/MqttDataWrapper.cpp

@@ -128,7 +128,9 @@ bool MqttDataWrapper::validateTopic(const daq::StringPtr topic, const daq::Logge
     if (!topic.assigned() || topic.getLength() == 0)
     {
         if (loggerComponent.assigned())
+        {
             LOG_W("Empty topic is not allowed!");
+        }
         return false;
     }
 
@@ -140,7 +142,9 @@ bool MqttDataWrapper::validateTopic(const daq::StringPtr topic, const daq::Logge
         if (part == "#" || part == "+")
         {
             if (loggerComponent.assigned())
+            {
                 LOG_W("Wildcard characters '+' and '#' are not allowed in topic: {}", topic.toStdString());
+            }
             return false;
         }
     }