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
 

modules/mqtt_streaming_module/tests/test_mqtt_publisher_fb.cpp

@@ -1469,8 +1469,6 @@ TEST_P(MqttPublisherFbPTest, TransferRaw)
 
 TEST_F(MqttPublisherFbTest, TransferRawString)
 {
-    constexpr size_t sampleCnt = 15;
-
     SignalHelper<std::string> help{};
     StartUp();
     ASSERT_NO_THROW(CreateRawPublisherFB());
@@ -1537,8 +1535,6 @@ TEST_F(MqttPublisherFbTest, TransferRawString)
 
 TEST_F(MqttPublisherFbTest, TransferRawBinaryData)
 {
-    constexpr size_t sampleCnt = 15;
-
     SignalHelper<BinarySample> help{};
     StartUp();
     ASSERT_NO_THROW(CreateRawPublisherFB());

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>