#443

lib/tools/mqtt_core.dart

@@ -153,7 +153,7 @@ class MqttCore {
     try {
       publishText(_toServerTopic, json);
     } catch (e) {
-      _enqueueMessage(topic, jsonEncode(payloadContainer.toJson()));
+      _enqueueMessage(_toServerTopic, jsonEncode(payloadContainer.toJson()));
     }
   }
 
@@ -495,8 +495,6 @@ class MqttCore {
     message.received.ver = job.ver;
     message.received.utc = DateTime.now().millisecondsSinceEpoch;
 
-    var json = jsonEncode(message.toJson());
-
     MqttCore.instance.publishPayloadMessage('job', message.toJson());
   }
 }