iot/sprocket-plugin-mqtt
1
0
Fork 0
mirror of https://gitlab.com/wirelos/sprocket-plugin-mqtt.git synced 2025-12-14 13:51:27 +01:00
Code Issues Packages Projects Releases Wiki Activity

remove some comments

Browse Source
This commit is contained in:
0x1d
2018-11-15 13:59:02 +01:00
parent fd6571caf5
commit bbf19d7170
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/MqttPlugin.cpp
View File

@@ -55,7 +55,7 @@ void MqttPlugin::connect()
void MqttPlugin::upstreamHandler(String topic, String msg) void MqttPlugin::upstreamHandler(String topic, String msg)
{ {
// publish message on remote queue // publish message on remote queue
PRINT_MSG(Serial, "MQTT", String("upstream: " + msg).c_str()); PRINT_MSG(Serial, "MQTT", String("publish remote: " + topic).c_str());
client->publish((String(mqttConfig.outTopicRoot) + topic).c_str(), msg.c_str()); client->publish((String(mqttConfig.outTopicRoot) + topic).c_str(), msg.c_str());
} }
@@ -72,6 +72,5 @@ void MqttPlugin::downstreamHandler(char *topic, uint8_t *payload, unsigned int l
String localTopic = String(topic).substring(topicRootLength); String localTopic = String(topic).substring(topicRootLength);
publish(localTopic, msg); publish(localTopic, msg);
PRINT_MSG(Serial, "MQTT", (String(topic) + " " + msg).c_str());
PRINT_MSG(Serial, "MQTT", (String("publish local: ") + localTopic).c_str()); PRINT_MSG(Serial, "MQTT", (String("publish local: ") + localTopic).c_str());
} }