fix

Author: viacheslauK

modules/mqtt_streaming_module/src/atomic_signal_sample_arr_handler.cpp

@@ -157,7 +157,7 @@ std::string AtomicSignalSampleArrayHandler::toString(const std::string valueFiel
 MqttDataSamplePtr AtomicSignalSampleArrayHandler::processDataPackets(SignalContext& signalContext)
 {
     if (signalBuffers[signalContext.inputPort.getSignal().getGlobalId().toStdString()].data.empty())
-        std::make_shared<MqttDataSample<std::string>>();
+        return std::make_shared<MqttDataSample<std::string>>();
     const auto signal = signalContext.inputPort.getSignal();
     std::string valueFieldName = buildValueFieldName(signalNamesMode, signal);
     auto msg = toString(valueFieldName, signalContext);

modules/mqtt_streaming_module/src/mqtt_subscriber_fb_impl.cpp

@@ -9,6 +9,7 @@
 #include <mqtt_streaming_module/property_helper.h>
 #include <opendaq/binary_data_packet_factory.h>
 #include <sstream>
+#include <chrono>
 
 BEGIN_NAMESPACE_OPENDAQ_MQTT_STREAMING_MODULE
 

shared/mqtt_streaming_protocol/src/MqttDataWrapper.cpp

@@ -5,6 +5,7 @@
 #include <opendaq/packet_factory.h>
 #include <opendaq/sample_type_traits.h>
 #include <rapidjson/document.h>
+#include <algorithm>
 
 #include <mqtt_streaming_protocol/utils.h>
 

shared/mqtt_streaming_protocol/src/utils.cpp

@@ -1,5 +1,3 @@
-#pragma once
-
 #include "mqtt_streaming_protocol/utils.h"
 #include <algorithm>
 #include <boost/date_time/posix_time/posix_time.hpp>