mqtt: fix downlink check
This commit is contained in:
+1
-1
@@ -88,7 +88,7 @@ void MQTT::sendSubscriptions()
|
|||||||
size_t numChan = channels.getNumChannels();
|
size_t numChan = channels.getNumChannels();
|
||||||
for (size_t i = 0; i < numChan; i++) {
|
for (size_t i = 0; i < numChan; i++) {
|
||||||
auto &ch = channels.getByIndex(i);
|
auto &ch = channels.getByIndex(i);
|
||||||
if (ch.settings.uplink_enabled) {
|
if (ch.settings.downlink_enabled) {
|
||||||
String topic = cryptTopic + channels.getGlobalId(i) + "/#";
|
String topic = cryptTopic + channels.getGlobalId(i) + "/#";
|
||||||
DEBUG_MSG("Subscribing to %s\n", topic.c_str());
|
DEBUG_MSG("Subscribing to %s\n", topic.c_str());
|
||||||
pubSub.subscribe(topic.c_str(), 1); // FIXME, is QOS 1 right?
|
pubSub.subscribe(topic.c_str(), 1); // FIXME, is QOS 1 right?
|
||||||
|
|||||||
Reference in New Issue
Block a user