Fehlerkorrekturen

lib/tools/mqtt_core.dart

@@ -487,28 +487,15 @@ class MqttCore {
     }
   }
 
-  /*
-  private void AcknowledgeJob(Job job)
-    {
-        var payloadObject = new JObject();
-
-        var receivedObject = new JObject();
-        payloadObject.Add(new JProperty("received", receivedObject));
-
-        receivedObject.Add(new JProperty("id", job.Id));
-        receivedObject.Add(new JProperty("state", job.State));
-        receivedObject.Add(new JProperty("ver", job.Ver));
-        receivedObject.Add(new JProperty("utc", Utils.GetUTCTimestamp()));
-
-        SendJsonMessageAsync("job", payloadObject);
-    }
-   */
   void _acknowlegdeJob(Job job) {
     var message = AcknowledgeJob();
-    message.id = job.id;
-    message.state = job.state;
-    message.ver = job.ver;
-    message.utc = DateTime.now().millisecondsSinceEpoch;
+    message.received = AcknowledgeJobReceived();
+    message.received.id = job.id;
+    message.received.state = job.state;
+    message.received.ver = job.ver;
+    message.received.utc = DateTime.now().millisecondsSinceEpoch;
+
+    var json = jsonEncode(message.toJson());
 
     MqttCore.instance.publishPayloadMessage('job', message.toJson());
   }