mqtt: refactoring

Author: viacheslauK

mqtt_streaming_protocol/include/MqttDataWrapper.h

@@ -52,8 +52,7 @@ class MqttDataWrapper final
     static std::string extractDeviceName(const std::string& topic);
 
     static std::string serializeSampleData(const SampleData& data);
-    static std::string serializeSignalDescriptors(
-        daq::ListObjectPtr<daq::IList, daq::ISignal, daq::GenericSignalPtr<daq::ISignal>> signals);
+    static std::string serializeSignalDescriptors(daq::ListPtr<daq::ISignal> signals);
 
     static std::string buildTopicFromId(const std::string& globalId);
     static std::string buildSignalsTopic(const std::string& deviceId);

mqtt_streaming_protocol/src/MqttDataWrapper.cpp

@@ -44,8 +44,7 @@ std::string MqttDataWrapper::serializeSampleData(const SampleData& data)
     return result;
 }
 
-std::string MqttDataWrapper::serializeSignalDescriptors(
-    daq::ListObjectPtr<daq::IList, daq::ISignal, daq::GenericSignalPtr<daq::ISignal>> signals)
+std::string MqttDataWrapper::serializeSignalDescriptors(daq::ListPtr<daq::ISignal> signals)
 {
     std::string result;
     rapidjson::Document doc;

mqtt_streaming_server_module/include/mqtt_streaming_server_module/mqtt_streaming_server_impl.h

@@ -68,7 +68,7 @@ class MqttStreamingServerImpl : public daq::Server
 
     static void populateDefaultConfigFromProvider(const ContextPtr& context, const PropertyObjectPtr& config);
 
-    daq::ListObjectPtr<daq::IList, daq::ISignal, daq::GenericSignalPtr<daq::ISignal>> signals;
+    daq::ListPtr<ISignal> signals;
     std::vector<StreamReaderPtr> streamReaders;
 
     std::string rootDeviceGlobalId;