Skip to content

Commit

Permalink
mqtt subscriptions include device #173
Browse files Browse the repository at this point in the history
  • Loading branch information
MichaelDvP committed Nov 3, 2021
1 parent fb3de2e commit af27101
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
4 changes: 2 additions & 2 deletions src/emsesp.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -1015,8 +1015,8 @@ bool EMSESP::add_device(const uint8_t device_id, const uint8_t product_id, std::
[device_type](const char * value, const int8_t id, JsonObject & output) { return command_entities(device_type, output, id); },
F_(entities_cmd));

// MQTT subscribe to the device top-level, e.g. "ems-esp/boiler/#"
std::string topic = EMSdevice::device_type_2_device_name(device_type) + "/#";
// MQTT subscribe to the device top-level, e.g. "ems-esp/boiler" and subs
std::string topic = EMSdevice::device_type_2_device_name(device_type) + "#";
Mqtt::subscribe(device_type, topic, nullptr); // use empty function callback

// Print to LOG showing we've added a new device
Expand Down
4 changes: 2 additions & 2 deletions src/system.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -699,8 +699,8 @@ void System::commands_init() {
Command::add(EMSdevice::DeviceType::SYSTEM, F("test"), System::command_test, F("run tests"));
#endif

// MQTT subscribe "ems-esp/system/#"
Mqtt::subscribe(EMSdevice::DeviceType::SYSTEM, "system/#", nullptr); // use empty function callback
// MQTT subscribe "ems-esp/system" and subs
Mqtt::subscribe(EMSdevice::DeviceType::SYSTEM, "system#", nullptr); // use empty function callback
}

// flashes the LED
Expand Down

0 comments on commit af27101

Please sign in to comment.