Skip to content

MQTT streaming client implementation#2

Merged
viacheslauK merged 46 commits intomainfrom
client
Oct 21, 2025
Merged

MQTT streaming client implementation#2
viacheslauK merged 46 commits intomainfrom
client

Conversation

@viacheslauK
Copy link
Copy Markdown
Collaborator

@viacheslauK viacheslauK commented Sep 23, 2025

Brief

  • MQTT openDAQ streaming client module;
  • Example applications;
  • Reworking MQTT client wrapper (PAHO wrapper);
  • Improving MQTT openDAQ streaming server module;
  • Tests for client and server MQTT modules;
  • Tests for MQTT client wrapper;

Description

  • Implementation of MQTT openDAQ streaming client module allows to receive and parse MQTT messages which adhere to a strict message structure. It allows discovering of MQTT openDAQ devices and communication with them.
  • The example applications demonstrate a typical approach to working with openDAQ MQTT modules.
  • MQTT client wrapper reworking changed the architecture of wrapper classes, removed unused functional and duplication of code. The previous approach with separate publisher and subscriber class was redesigned into single client class.
  • New tests for client and server MQTT modules.
  • New tests for MQTT client wrapper allow to test communication with a MQTT brocker and messaging between clients.

@viacheslauK viacheslauK self-assigned this Sep 23, 2025
@viacheslauK viacheslauK marked this pull request as ready for review October 9, 2025 08:39
Comment thread mqtt_streaming_client_module/src/mqtt_streaming_device_impl.cpp
Comment thread mqtt_streaming_client_module/src/mqtt_streaming_device_impl.cpp
Comment thread mqtt_streaming_client_module/src/mqtt_streaming_device_impl.cpp Outdated
Comment thread mqtt_streaming_client_module/src/mqtt_streaming_device_impl.cpp Outdated
Comment thread mqtt_streaming_protocol/src/CMakeLists.txt
Copy link
Copy Markdown

@NikolaiShipilov NikolaiShipilov left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Shortlist of things to be addressed before merge:

  • broken boost dependencies - since source code uses some boost functionality #include <boost/...> - the corresponding dependencies should be explicitly set within CMake
    * add dependencies required for tests with CMake
  • pthread linkage missing within example and test apps

Comment thread mqtt_streaming_server_module/CMakeLists.txt Outdated
Comment thread examples/ref-dev-mqtt-sub/src/CMakeLists.txt
Comment thread mqtt_streaming_protocol/tests/test_mqtt_streaming_protocol.cpp
Comment thread external/mqtt/CMakeLists.txt Outdated
@viacheslauK viacheslauK merged commit 65cc0d1 into main Oct 21, 2025
@viacheslauK viacheslauK deleted the client branch December 8, 2025 09:23
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants