Skip to content

MQTT raw and publisher FB improving#7

Merged
viacheslauK merged 14 commits intomainfrom
publisher-improving
Dec 25, 2025
Merged

MQTT raw and publisher FB improving#7
viacheslauK merged 14 commits intomainfrom
publisher-improving

Conversation

@viacheslauK
Copy link
Copy Markdown
Collaborator

@viacheslauK viacheslauK commented Dec 17, 2025

Brief:

  • Raw FB: one FB - one topic; "Topic" property;
  • Raw FB: SubscriptionStatus;
  • Raw FB: dynamic application of properties;
  • Raw FB, JSON FB: localId to create multiple objects;
  • Publisher FB: "Topic" property for Multi mode;
  • Publisher FB: PublishingStatus;
  • Publisher FB: SignalStatus;
  • Publisher FB: dynamic application of properties;
  • Tests;

@viacheslauK viacheslauK changed the title MQTT publisher FB improving MQTT raw and publisher FB improving Dec 23, 2025
@viacheslauK viacheslauK self-assigned this Dec 23, 2025
@viacheslauK viacheslauK marked this pull request as ready for review December 23, 2025 09:14
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.

lgtm 👍 .
Added comments, as usual, could be fixed (if applicable) in the following PRs.
Also, I would suggest renaming of mqtt_base_fb.h/cpp and containing class by adding word "receiver" there to distinct it from publisherFb and rootFb.


void restart()
{
firstStart = false;
Copy link
Copy Markdown

Choose a reason for hiding this comment

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

Seems like that assignment should go last in this method - after start value is initialized

Comment thread mqtt_streaming_module/src/mqtt_base_fb.cpp
Comment thread mqtt_streaming_module/src/mqtt_base_fb.cpp
Comment on lines +93 to +96
const std::string msg = "MQTT subscriber client is not set!";
setComponentStatusWithMessage(ComponentStatus::Error, msg);
setSubscriptionStatus(SubscriptionStatus::SubscribingError, msg);
result = {false, msg};
Copy link
Copy Markdown

Choose a reason for hiding this comment

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

"MQTT subscriber client is not set!" message is a bit confusing for end-user as it refers to internal implementation details.
Anyway, here and in unsubscribeFromTopic the case when MqttAsyncClient class-member pointer is not assigned seems not reachable.

@viacheslauK viacheslauK merged commit 8d6a0ee into main Dec 25, 2025
@viacheslauK viacheslauK deleted the publisher-improving branch January 28, 2026 10:15
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