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

print remote topic

Browse Source
This commit is contained in:
0x1d
2018-11-16 00:28:46 +01:00
parent bbf19d7170
commit 0a5bfc8cf9
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/MqttPlugin.cpp
View File

@@ -55,8 +55,9 @@ 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("publish remote: " + topic).c_str()); String remoteTopic = String(mqttConfig.outTopicRoot) + topic;
client->publish((String(mqttConfig.outTopicRoot) + topic).c_str(), msg.c_str()); client->publish(remoteTopic.c_str(), msg.c_str());
PRINT_MSG(Serial, "MQTT", String("publish remote: " + remoteTopic).c_str());
} }
void MqttPlugin::downstreamHandler(char *topic, uint8_t *payload, unsigned int length) void MqttPlugin::downstreamHandler(char *topic, uint8_t *payload, unsigned int length)