diff --git a/src/MqttPlugin.cpp b/src/MqttPlugin.cpp index a505053..06ed736 100644 --- a/src/MqttPlugin.cpp +++ b/src/MqttPlugin.cpp @@ -55,8 +55,9 @@ void MqttPlugin::connect() void MqttPlugin::upstreamHandler(String topic, String msg) { // publish message on remote queue - PRINT_MSG(Serial, "MQTT", String("publish remote: " + topic).c_str()); - client->publish((String(mqttConfig.outTopicRoot) + topic).c_str(), msg.c_str()); + String remoteTopic = String(mqttConfig.outTopicRoot) + topic; + 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)