diff --git a/logs/application.log b/logs/application.log
index 2be6d05..45ca94e 100644
--- a/logs/application.log
+++ b/logs/application.log
@@ -1528,3 +1528,1055 @@ org.sqlite.SQLiteException: [SQLITE_ERROR] SQL error or missing database (no suc
[2026-02-23 19:58:56] [INFO] [PROCESS] Externe Prozesse beendet
[2026-02-23 19:58:56] [INFO] [SYSTEM] Programm wird beendet
[2026-02-23 19:58:56] [INFO] [SYSTEM] Datenbank gelöscht
+[2026-02-23 20:21:17] [INFO] [MQTT] Verbinde mit Broker tcp://localhost:1883
+[2026-02-23 20:21:18] [INFO] [MQTT] Verbindung hergestellt
+[2026-02-23 20:21:18] [INFO] [DB] Datenbank initialisiert
+[2026-02-23 20:21:18] [INFO] [MQTT] Topic abonniert: PREDICTION
+[2026-02-23 20:21:18] [INFO] [Controller] Subscribe AppState Observer gestartet
+[2026-02-23 20:21:18] [INFO] [Controller] AppState Observer registriert
+[2026-02-23 20:28:13] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:28:13] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:29:24] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:29:24] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:29:30] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:29:30] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:29:36] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:29:36] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:29:42] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:29:42] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:29:48] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:29:48] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:29:54] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:29:54] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:30:00] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:30:00] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:30:06] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:30:06] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:30:12] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:30:12] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:30:18] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:30:18] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:30:25] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:30:25] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:30:30] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:30:30] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:30:36] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:30:36] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:30:42] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:30:42] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:30:48] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:30:48] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:30:54] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:30:54] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:31:00] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:31:00] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:31:06] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:31:06] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:31:12] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:31:12] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:31:18] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:31:18] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:31:24] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:31:24] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:31:30] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:31:30] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:31:36] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:31:36] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:31:42] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:31:42] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:31:48] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:31:48] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:31:54] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:31:54] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:32:00] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:32:00] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:32:06] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:32:06] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:32:12] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:32:12] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:32:18] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:32:18] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:32:24] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:32:24] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:32:30] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:32:30] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:32:36] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:32:36] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:32:42] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:32:42] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:32:48] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:32:48] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:32:54] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:32:54] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:33:00] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:33:00] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:33:06] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:33:06] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:33:13] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:33:13] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:33:18] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:33:18] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:33:23] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:33:23] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:33:29] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:33:29] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:33:35] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:33:35] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:33:42] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:33:42] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:33:47] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:33:47] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:33:53] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:33:53] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:33:59] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:33:59] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:34:05] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:34:05] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:34:11] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:34:11] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:34:17] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:34:17] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:34:23] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:34:23] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:34:29] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:34:29] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:34:35] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:34:35] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:34:41] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:34:41] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:34:47] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:34:47] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:34:53] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:34:53] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:34:59] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:34:59] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:35:05] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:35:05] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:35:12] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:35:12] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:35:17] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:35:17] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:35:23] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:35:23] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:35:29] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:35:29] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:35:34] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:35:34] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:35:40] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:35:40] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:35:45] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:35:45] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:35:51] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:35:51] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:35:57] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:35:57] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:36:03] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:36:03] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:36:09] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:36:09] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:36:15] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:36:15] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:36:21] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:36:21] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:36:27] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:36:27] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:36:34] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:36:34] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:36:40] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:36:40] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:36:45] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:36:45] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:36:51] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:36:51] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:36:57] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:36:57] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:37:03] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:37:03] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:37:10] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:37:10] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:37:15] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:37:15] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:37:21] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:37:21] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:37:27] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:37:27] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:37:33] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:37:33] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:37:39] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:37:39] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:37:45] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:37:45] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:37:51] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:37:51] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:37:57] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:37:57] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:38:03] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:38:03] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:38:09] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:38:09] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:38:14] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:38:14] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:38:20] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:38:20] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:38:26] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:38:26] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:38:32] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:38:32] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:38:38] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:38:38] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:38:44] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:38:44] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:38:50] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:38:50] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:38:56] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:38:56] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:39:02] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:39:02] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:39:08] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:39:08] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:39:13] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:39:13] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:39:19] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:39:19] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:39:25] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:39:25] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:39:30] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:39:30] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:39:36] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:39:36] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:39:42] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:39:42] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:39:48] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:39:48] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:39:55] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:39:55] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:40:00] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:40:00] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:40:06] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:40:06] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:40:12] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:40:12] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:40:18] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:40:18] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:40:25] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:40:25] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:40:30] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:40:30] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:40:36] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:40:36] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:40:42] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:40:42] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:40:48] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:40:48] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:40:54] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:40:54] [WARN] [EVENT] Payload nicht numerisch {"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:40:58] [INFO] [MQTT] Verbinde mit Broker tcp://localhost:1883
+[2026-02-23 20:40:59] [INFO] [MQTT] Verbindung hergestellt
+[2026-02-23 20:40:59] [INFO] [DB] Datenbank initialisiert
+[2026-02-23 20:40:59] [INFO] [MQTT] Topic abonniert: PREDICTION
+[2026-02-23 20:40:59] [INFO] [Controller] Subscribe AppState Observer gestartet
+[2026-02-23 20:40:59] [INFO] [Controller] AppState Observer registriert
+[2026-02-23 20:41:00] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:41:00] [DEBUG] [DB] Database Insert erfolgreich: INSERT INTO binary_event (value, timestamp) VALUES (?, ?)
+ parameters=[1, 2026-02-23T20:41:00.685124300]
+[2026-02-23 20:41:00] [DEBUG] [Controller] AppState Update erhalten: DISASTER
+[2026-02-23 20:41:00] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 20:41:00] [WARN] [UNREAL] Nicht verbunden! Text wird nicht gesendet!
+[2026-02-23 20:41:00] [DEBUG] [Controller] AppState Update erhalten: DISASTER
+[2026-02-23 20:41:00] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 20:41:00] [DEBUG] [EVENT] Prediction verarbeitet: 1
+[2026-02-23 20:41:06] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:41:06] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:41:12] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:41:12] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:41:17] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:41:17] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:41:23] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:41:23] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:41:29] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:41:29] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:41:35] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:41:35] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:41:41] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:41:41] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:41:47] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:41:47] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:41:53] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:41:53] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:41:59] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:41:59] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:42:05] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:42:05] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:42:11] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:42:11] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:42:17] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:42:17] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:42:23] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:42:23] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:42:29] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:42:29] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:42:35] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:42:35] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:42:41] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:42:41] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:42:47] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:42:47] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:42:53] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:42:53] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:42:59] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:42:59] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:43:05] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:43:05] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:43:11] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:43:11] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:43:17] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:43:17] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:43:23] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:43:23] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:43:29] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:43:29] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:43:35] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:43:35] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:43:41] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:43:41] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:43:47] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:43:47] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:43:53] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:43:53] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:43:59] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:43:59] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:44:05] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:44:05] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:44:11] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:44:11] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:44:17] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:44:17] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:44:23] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:44:23] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:44:29] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:44:29] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:44:35] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:44:35] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:44:41] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:44:41] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:44:47] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:44:47] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:44:53] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:44:53] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:44:59] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:44:59] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:45:05] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:45:05] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:45:11] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:45:11] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:45:17] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:45:17] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:45:23] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:45:23] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:45:29] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:45:29] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:45:35] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:45:35] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:45:41] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:45:41] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:45:47] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:45:47] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:45:54] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:45:54] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:45:59] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:45:59] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:46:05] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:46:05] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:46:11] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:46:11] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:46:17] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:46:17] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:46:23] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:46:23] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:46:29] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:46:29] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:46:35] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:46:35] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:46:41] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:46:41] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:46:47] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:46:47] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:46:53] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:46:53] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:46:59] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:46:59] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:47:05] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:47:05] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:47:11] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:47:11] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:47:17] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:47:17] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:47:23] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:47:23] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:47:29] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:47:29] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:47:35] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:47:35] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:47:41] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:47:41] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:47:47] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:47:47] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:47:53] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:47:53] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:47:59] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:47:59] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:48:05] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:48:05] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:48:11] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:48:11] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:48:17] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:48:17] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:48:23] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:48:23] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:48:29] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:48:29] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:48:35] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:48:35] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:48:41] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:48:41] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:48:47] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:48:47] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:48:53] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:48:53] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:48:59] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:48:59] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:49:05] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:49:05] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:49:11] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:49:11] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:49:17] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:49:17] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:49:23] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:49:23] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:49:29] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:49:29] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:49:35] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:49:35] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:49:41] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:49:41] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:49:47] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:49:47] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:49:53] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:49:53] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:49:59] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:49:59] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:50:05] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:50:05] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:50:11] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:50:11] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:50:17] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:50:17] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:50:23] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:50:23] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:50:29] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:50:29] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:50:35] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:50:35] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:50:41] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:50:41] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:50:47] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:50:47] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:50:53] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:50:53] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:50:59] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:50:59] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:51:05] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:51:05] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:51:11] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:51:11] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:51:17] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:51:17] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:51:22] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:51:22] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:51:28] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:51:28] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:51:34] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:51:34] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:51:40] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:51:40] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:51:46] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:51:46] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:51:52] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:51:52] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:51:58] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:51:58] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:52:04] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:52:04] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:52:10] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:52:10] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:52:16] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:52:16] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:52:22] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:52:22] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:52:28] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:52:28] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:52:34] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:52:34] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:52:40] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:52:40] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:52:47] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:52:47] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:52:52] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:52:52] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:52:57] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:52:57] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:53:03] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:53:03] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:53:09] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:53:09] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:53:14] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:53:14] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:53:20] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:53:20] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:53:27] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:53:27] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:53:32] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:53:32] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:53:39] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:53:39] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:53:44] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:53:44] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:53:50] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:53:50] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:53:56] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:53:56] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:54:02] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:54:02] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:54:08] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:54:08] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:54:14] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:54:14] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:54:20] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:54:20] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:54:26] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:54:26] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:54:32] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:54:32] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:54:38] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:54:38] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:54:44] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:54:44] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:54:50] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:54:50] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:54:56] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:54:56] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:55:02] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:55:02] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:55:08] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:55:08] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:55:14] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:55:14] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:55:20] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:55:20] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:55:26] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:55:26] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:55:32] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:55:32] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:55:38] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:55:38] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:55:44] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:55:44] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:55:50] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:55:50] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:55:56] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:55:56] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:56:02] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:56:02] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:56:08] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:56:08] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:56:14] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:56:14] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:56:20] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:56:20] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:56:26] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:56:26] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:56:32] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:56:32] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:56:38] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:56:38] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:56:44] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:56:44] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:56:50] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:56:50] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:56:59] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:56:59] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:57:02] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:57:02] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:57:07] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:57:07] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 20:57:12] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 20:57:12] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:09:20] [INFO] [MQTT] Verbinde mit Broker tcp://localhost:1883
+[2026-02-23 21:09:20] [INFO] [MQTT] Verbindung hergestellt
+[2026-02-23 21:09:20] [INFO] [DB] Datenbank initialisiert
+[2026-02-23 21:09:20] [INFO] [MQTT] Topic abonniert: PREDICTION
+[2026-02-23 21:09:20] [INFO] [Controller] Subscribe AppState Observer gestartet
+[2026-02-23 21:09:20] [INFO] [Controller] AppState Observer registriert
+[2026-02-23 21:09:23] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:09:23] [DEBUG] [DB] Database Insert erfolgreich: INSERT INTO binary_event (value, timestamp) VALUES (?, ?)
+ parameters=[1, 2026-02-23T21:09:23.584116800]
+[2026-02-23 21:09:23] [DEBUG] [Controller] AppState Update erhalten: DISASTER
+[2026-02-23 21:09:23] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:09:23] [WARN] [UNREAL] Nicht verbunden! Text wird nicht gesendet!
+[2026-02-23 21:09:23] [DEBUG] [Controller] AppState Update erhalten: DISASTER
+[2026-02-23 21:09:23] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:09:23] [DEBUG] [EVENT] Prediction verarbeitet: 1
+[2026-02-23 21:09:29] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:09:29] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:09:35] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:09:35] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:09:41] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:09:41] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:09:42] [INFO] [MQTT] Verbindung getrennt
+[2026-02-23 21:09:42] [INFO] [PROCESS] Externe Prozesse beendet
+[2026-02-23 21:09:42] [INFO] [SYSTEM] Programm wird beendet
+[2026-02-23 21:09:42] [INFO] [SYSTEM] Datenbank gelöscht
+[2026-02-23 21:09:48] [INFO] [MQTT] Verbinde mit Broker tcp://localhost:1883
+[2026-02-23 21:09:48] [INFO] [MQTT] Verbindung hergestellt
+[2026-02-23 21:09:48] [INFO] [DB] Datenbank initialisiert
+[2026-02-23 21:09:48] [INFO] [MQTT] Topic abonniert: PREDICTION
+[2026-02-23 21:09:48] [INFO] [Controller] Subscribe AppState Observer gestartet
+[2026-02-23 21:09:48] [INFO] [Controller] AppState Observer registriert
+[2026-02-23 21:09:53] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:09:53] [DEBUG] [DB] Database Insert erfolgreich: INSERT INTO binary_event (value, timestamp) VALUES (?, ?)
+ parameters=[1, 2026-02-23T21:09:53.975588100]
+[2026-02-23 21:09:53] [DEBUG] [Controller] AppState Update erhalten: DISASTER
+[2026-02-23 21:09:53] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:09:54] [WARN] [UNREAL] Nicht verbunden! Text wird nicht gesendet!
+[2026-02-23 21:09:54] [DEBUG] [Controller] AppState Update erhalten: DISASTER
+[2026-02-23 21:09:54] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:09:54] [DEBUG] [EVENT] Prediction verarbeitet: 1
+[2026-02-23 21:09:59] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:09:59] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:10:05] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:10:05] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:10:11] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:10:11] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:10:17] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:10:17] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:10:23] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:10:23] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:10:29] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:10:29] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:10:35] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:10:35] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:10:41] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:10:41] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:10:47] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:10:47] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:10:53] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:10:53] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:10:59] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:10:59] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:11:05] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:11:05] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:11:11] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:11:11] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:11:17] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:11:17] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:11:23] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:11:23] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:11:29] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:11:29] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:11:35] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:11:35] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:11:41] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:11:41] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:11:47] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:11:47] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:11:53] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:11:53] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:11:59] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:11:59] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:12:05] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:12:05] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:12:11] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:12:11] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:12:17] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:12:17] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:12:23] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:12:23] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:12:29] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:12:29] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:12:35] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:12:35] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:12:41] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:12:41] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:12:47] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:12:47] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:12:53] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:12:53] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:12:59] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:12:59] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:13:05] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:13:05] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:13:11] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:13:11] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:13:17] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:13:17] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:13:23] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:13:23] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:13:29] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:13:29] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:13:35] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:13:35] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:13:41] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:13:41] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:13:47] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:13:47] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:13:53] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:13:53] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:13:59] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:13:59] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:14:05] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:14:05] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:14:11] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:14:11] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:14:17] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:14:17] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:14:23] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:14:23] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:14:29] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:14:29] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:14:35] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:14:35] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:14:41] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:14:41] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:14:47] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:14:47] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:14:53] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:14:53] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:14:59] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:14:59] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:15:05] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:15:05] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:15:11] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:15:11] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:15:17] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:15:17] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:15:23] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:15:23] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:15:29] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:15:29] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:15:35] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:15:35] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:15:41] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:15:41] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:15:47] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:15:47] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:15:53] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:15:53] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:15:59] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:15:59] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:16:05] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:16:05] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:16:11] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:16:11] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:16:17] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:16:17] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:16:23] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:16:23] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:16:29] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:16:29] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:16:35] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:16:35] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:16:41] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:16:41] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:16:47] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:16:47] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:16:53] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:16:53] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:16:59] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:16:59] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:17:05] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:17:05] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:17:11] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:17:11] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:17:17] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:17:17] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:17:23] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:17:23] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:17:29] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:17:29] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:17:35] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:17:35] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:17:41] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:17:41] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:17:47] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:17:47] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:17:53] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:17:53] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:17:59] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:17:59] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:18:05] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:18:05] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:18:11] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:18:11] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:18:18] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:18:18] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:18:23] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:18:23] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:18:29] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:18:29] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:18:36] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 252, "prediction": 1}
+[2026-02-23 21:18:36] [WARN] [EVENT] Payload ID bereits verarbeitet: 252
+[2026-02-23 21:18:42] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 253, "prediction": 1}
+[2026-02-23 21:18:42] [DEBUG] [DB] Database Insert erfolgreich: INSERT INTO binary_event (value, timestamp) VALUES (?, ?)
+ parameters=[1, 2026-02-23T21:18:42.948218400]
+[2026-02-23 21:18:42] [DEBUG] [Controller] AppState Update erhalten: DISASTER
+[2026-02-23 21:18:42] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:18:42] [WARN] [UNREAL] Nicht verbunden! Text wird nicht gesendet!
+[2026-02-23 21:18:42] [DEBUG] [Controller] AppState Update erhalten: DISASTER
+[2026-02-23 21:18:42] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:18:42] [DEBUG] [EVENT] Prediction verarbeitet: 1
+[2026-02-23 21:18:48] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 253, "prediction": 1}
+[2026-02-23 21:18:48] [WARN] [EVENT] Payload ID bereits verarbeitet: 253
+[2026-02-23 21:18:54] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 253, "prediction": 1}
+[2026-02-23 21:18:54] [WARN] [EVENT] Payload ID bereits verarbeitet: 253
+[2026-02-23 21:18:59] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 254, "prediction": 1}
+[2026-02-23 21:18:59] [DEBUG] [DB] Database Insert erfolgreich: INSERT INTO binary_event (value, timestamp) VALUES (?, ?)
+ parameters=[1, 2026-02-23T21:18:59.912506500]
+[2026-02-23 21:18:59] [DEBUG] [Controller] AppState Update erhalten: DISASTER
+[2026-02-23 21:18:59] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:18:59] [WARN] [UNREAL] Nicht verbunden! Text wird nicht gesendet!
+[2026-02-23 21:18:59] [DEBUG] [Controller] AppState Update erhalten: DISASTER
+[2026-02-23 21:18:59] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:18:59] [DEBUG] [EVENT] Prediction verarbeitet: 1
+[2026-02-23 21:19:06] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 254, "prediction": 1}
+[2026-02-23 21:19:06] [WARN] [EVENT] Payload ID bereits verarbeitet: 254
+[2026-02-23 21:19:11] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 255, "prediction": 1}
+[2026-02-23 21:19:11] [DEBUG] [DB] Database Insert erfolgreich: INSERT INTO binary_event (value, timestamp) VALUES (?, ?)
+ parameters=[1, 2026-02-23T21:19:11.921128500]
+[2026-02-23 21:19:11] [DEBUG] [Controller] AppState Update erhalten: DISASTER
+[2026-02-23 21:19:11] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:19:11] [WARN] [UNREAL] Nicht verbunden! Text wird nicht gesendet!
+[2026-02-23 21:19:11] [DEBUG] [Controller] AppState Update erhalten: DISASTER
+[2026-02-23 21:19:11] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:19:11] [DEBUG] [EVENT] Prediction verarbeitet: 1
+[2026-02-23 21:19:17] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 255, "prediction": 1}
+[2026-02-23 21:19:17] [WARN] [EVENT] Payload ID bereits verarbeitet: 255
+[2026-02-23 21:19:24] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 255, "prediction": 1}
+[2026-02-23 21:19:24] [WARN] [EVENT] Payload ID bereits verarbeitet: 255
+[2026-02-23 21:19:24] [INFO] [MQTT] Verbindung getrennt
+[2026-02-23 21:19:24] [INFO] [PROCESS] Externe Prozesse beendet
+[2026-02-23 21:19:24] [INFO] [SYSTEM] Programm wird beendet
+[2026-02-23 21:19:24] [INFO] [SYSTEM] Datenbank gelöscht
+[2026-02-23 21:19:28] [INFO] [MQTT] Verbinde mit Broker tcp://localhost:1883
+[2026-02-23 21:19:29] [INFO] [MQTT] Verbindung hergestellt
+[2026-02-23 21:19:29] [INFO] [DB] Datenbank initialisiert
+[2026-02-23 21:19:29] [INFO] [MQTT] Topic abonniert: PREDICTION
+[2026-02-23 21:19:29] [INFO] [Controller] Subscribe AppState Observer gestartet
+[2026-02-23 21:19:29] [INFO] [Controller] AppState Observer registriert
+[2026-02-23 21:19:29] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 256, "prediction": 1}
+[2026-02-23 21:19:30] [DEBUG] [DB] Database Insert erfolgreich: INSERT INTO binary_event (value, timestamp) VALUES (?, ?)
+ parameters=[1, 2026-02-23T21:19:29.995711400]
+[2026-02-23 21:19:30] [DEBUG] [Controller] AppState Update erhalten: DISASTER
+[2026-02-23 21:19:30] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:19:30] [WARN] [UNREAL] Nicht verbunden! Text wird nicht gesendet!
+[2026-02-23 21:19:30] [DEBUG] [Controller] AppState Update erhalten: DISASTER
+[2026-02-23 21:19:30] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:19:30] [DEBUG] [EVENT] Prediction verarbeitet: 1
+[2026-02-23 21:19:36] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 256, "prediction": 1}
+[2026-02-23 21:19:36] [WARN] [EVENT] Payload ID bereits verarbeitet: 256
+[2026-02-23 21:19:42] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 256, "prediction": 1}
+[2026-02-23 21:19:42] [WARN] [EVENT] Payload ID bereits verarbeitet: 256
+[2026-02-23 21:19:47] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 257, "prediction": 1}
+[2026-02-23 21:19:47] [DEBUG] [DB] Database Insert erfolgreich: INSERT INTO binary_event (value, timestamp) VALUES (?, ?)
+ parameters=[1, 2026-02-23T21:19:47.954381800]
+[2026-02-23 21:19:47] [DEBUG] [Controller] AppState Update erhalten: DISASTER
+[2026-02-23 21:19:47] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:19:47] [WARN] [UNREAL] Nicht verbunden! Text wird nicht gesendet!
+[2026-02-23 21:19:47] [DEBUG] [Controller] AppState Update erhalten: DISASTER
+[2026-02-23 21:19:47] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:19:47] [DEBUG] [EVENT] Prediction verarbeitet: 1
+[2026-02-23 21:19:53] [DEBUG] [MQTT] Nachricht empfangen -> Topic=PREDICTION, Payload={"valid": true, "_id": 257, "prediction": 1}
+[2026-02-23 21:19:53] [WARN] [EVENT] Payload ID bereits verarbeitet: 257
+[2026-02-23 21:20:53] [INFO] [MQTT] Verbinde mit Broker tcp://localhost:1883
+[2026-02-23 21:20:53] [INFO] [MQTT] Verbindung hergestellt
+[2026-02-23 21:20:53] [INFO] [DB] Datenbank initialisiert
+[2026-02-23 21:20:53] [INFO] [MQTT] Topic abonniert: PREDICTION
+[2026-02-23 21:20:53] [INFO] [Controller] Subscribe AppState Observer gestartet
+[2026-02-23 21:20:53] [INFO] [Controller] AppState Observer registriert
+[2026-02-23 21:20:54] [DEBUG] [DB] Database Insert erfolgreich: INSERT INTO binary_event (value, timestamp) VALUES (?, ?)
+ parameters=[1, 2026-02-23T21:20:54.074040200]
+[2026-02-23 21:20:54] [DEBUG] [Controller] AppState Update erhalten: DISASTER
+[2026-02-23 21:20:54] [WARN] [Controller] Window ist null, UI Update übersprungen
+[2026-02-23 21:20:54] [WARN] [UNREAL] Nicht verbunden! Text wird nicht gesendet!
+[2026-02-23 21:20:54] [DEBUG] [Controller] AppState Update erhalten: DISASTER
+[2026-02-23 21:20:54] [WARN] [Controller] Window ist null, UI Update übersprungen
+[2026-02-23 21:20:54] [DEBUG] [EVENT] Prediction verarbeitet: 1
+[2026-02-23 21:21:00] [DEBUG] [DB] Database Insert erfolgreich: INSERT INTO binary_event (value, timestamp) VALUES (?, ?)
+ parameters=[1, 2026-02-23T21:21:00.058053600]
+[2026-02-23 21:21:00] [DEBUG] [Controller] AppState Update erhalten: DISASTER
+[2026-02-23 21:21:00] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:21:00] [WARN] [UNREAL] Nicht verbunden! Text wird nicht gesendet!
+[2026-02-23 21:21:00] [DEBUG] [Controller] AppState Update erhalten: DISASTER
+[2026-02-23 21:21:00] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:21:00] [DEBUG] [EVENT] Prediction verarbeitet: 1
+[2026-02-23 21:21:05] [WARN] [EVENT] Payload ID bereits verarbeitet: 263
+[2026-02-23 21:21:11] [DEBUG] [DB] Database Insert erfolgreich: INSERT INTO binary_event (value, timestamp) VALUES (?, ?)
+ parameters=[1, 2026-02-23T21:21:11.926497400]
+[2026-02-23 21:21:11] [DEBUG] [Controller] AppState Update erhalten: DISASTER
+[2026-02-23 21:21:11] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:21:11] [WARN] [UNREAL] Nicht verbunden! Text wird nicht gesendet!
+[2026-02-23 21:21:11] [DEBUG] [Controller] AppState Update erhalten: DISASTER
+[2026-02-23 21:21:11] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:21:11] [DEBUG] [EVENT] Prediction verarbeitet: 1
+[2026-02-23 21:21:17] [WARN] [EVENT] Payload ID bereits verarbeitet: 264
+[2026-02-23 21:21:24] [DEBUG] [DB] Database Insert erfolgreich: INSERT INTO binary_event (value, timestamp) VALUES (?, ?)
+ parameters=[1, 2026-02-23T21:21:24.140724300]
+[2026-02-23 21:21:24] [DEBUG] [Controller] AppState Update erhalten: DISASTER
+[2026-02-23 21:21:24] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:21:24] [WARN] [UNREAL] Nicht verbunden! Text wird nicht gesendet!
+[2026-02-23 21:21:24] [DEBUG] [Controller] AppState Update erhalten: DISASTER
+[2026-02-23 21:21:24] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:21:24] [DEBUG] [EVENT] Prediction verarbeitet: 1
+[2026-02-23 21:21:30] [WARN] [EVENT] Payload ID bereits verarbeitet: 265
+[2026-02-23 21:21:36] [INFO] [MQTT] Verbinde mit Broker tcp://localhost:1883
+[2026-02-23 21:21:37] [INFO] [MQTT] Verbindung hergestellt
+[2026-02-23 21:21:37] [INFO] [DB] Datenbank initialisiert
+[2026-02-23 21:21:37] [INFO] [MQTT] Topic abonniert: PREDICTION
+[2026-02-23 21:21:37] [INFO] [Controller] Subscribe AppState Observer gestartet
+[2026-02-23 21:21:37] [INFO] [Controller] AppState Observer registriert
+[2026-02-23 21:21:42] [DEBUG] [DB] Database Insert erfolgreich: INSERT INTO binary_event (value, timestamp) VALUES (?, ?)
+ parameters=[1, 2026-02-23T21:21:42.196169500]
+[2026-02-23 21:21:42] [DEBUG] [Controller] AppState Update erhalten: DISASTER
+[2026-02-23 21:21:42] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:21:42] [WARN] [UNREAL] Nicht verbunden! Text wird nicht gesendet!
+[2026-02-23 21:21:42] [DEBUG] [Controller] AppState Update erhalten: DISASTER
+[2026-02-23 21:21:42] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:21:48] [WARN] [EVENT] Payload ID bereits verarbeitet: 266
+[2026-02-23 21:21:54] [DEBUG] [DB] Database Insert erfolgreich: INSERT INTO binary_event (value, timestamp) VALUES (?, ?)
+ parameters=[1, 2026-02-23T21:21:54.150673100]
+[2026-02-23 21:21:54] [DEBUG] [Controller] AppState Update erhalten: DISASTER
+[2026-02-23 21:21:54] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:21:54] [WARN] [UNREAL] Nicht verbunden! Text wird nicht gesendet!
+[2026-02-23 21:21:54] [DEBUG] [Controller] AppState Update erhalten: DISASTER
+[2026-02-23 21:21:54] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:22:00] [WARN] [EVENT] Payload ID bereits verarbeitet: 267
+[2026-02-23 21:22:05] [DEBUG] [DB] Database Insert erfolgreich: INSERT INTO binary_event (value, timestamp) VALUES (?, ?)
+ parameters=[1, 2026-02-23T21:22:05.955771200]
+[2026-02-23 21:22:05] [DEBUG] [Controller] AppState Update erhalten: DISASTER
+[2026-02-23 21:22:05] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:22:05] [WARN] [UNREAL] Nicht verbunden! Text wird nicht gesendet!
+[2026-02-23 21:22:05] [DEBUG] [Controller] AppState Update erhalten: DISASTER
+[2026-02-23 21:22:05] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:22:12] [WARN] [EVENT] Payload ID bereits verarbeitet: 268
+[2026-02-23 21:22:18] [DEBUG] [DB] Database Insert erfolgreich: INSERT INTO binary_event (value, timestamp) VALUES (?, ?)
+ parameters=[1, 2026-02-23T21:22:18.609212600]
+[2026-02-23 21:22:18] [DEBUG] [Controller] AppState Update erhalten: DISASTER
+[2026-02-23 21:22:18] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:22:18] [WARN] [UNREAL] Nicht verbunden! Text wird nicht gesendet!
+[2026-02-23 21:22:18] [DEBUG] [Controller] AppState Update erhalten: DISASTER
+[2026-02-23 21:22:18] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:22:25] [INFO] [MQTT] Verbinde mit Broker tcp://localhost:1883
+[2026-02-23 21:22:26] [INFO] [MQTT] Verbindung hergestellt
+[2026-02-23 21:22:26] [INFO] [DB] Datenbank initialisiert
+[2026-02-23 21:22:26] [INFO] [MQTT] Topic abonniert: PREDICTION
+[2026-02-23 21:22:26] [INFO] [Controller] Subscribe AppState Observer gestartet
+[2026-02-23 21:22:26] [INFO] [Controller] AppState Observer registriert
+[2026-02-23 21:22:29] [DEBUG] [DB] Database Insert erfolgreich: INSERT INTO binary_event (value, timestamp) VALUES (?, ?)
+ parameters=[1, 2026-02-23T21:22:29.941992900]
+[2026-02-23 21:22:29] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:22:29] [WARN] [UNREAL] Nicht verbunden! Text wird nicht gesendet!
+[2026-02-23 21:22:29] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:22:35] [DEBUG] [DB] Database Insert erfolgreich: INSERT INTO binary_event (value, timestamp) VALUES (?, ?)
+ parameters=[1, 2026-02-23T21:22:35.964215200]
+[2026-02-23 21:22:35] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:22:35] [WARN] [UNREAL] Nicht verbunden! Text wird nicht gesendet!
+[2026-02-23 21:22:35] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:22:42] [WARN] [EVENT] Payload ID bereits verarbeitet: 271
+[2026-02-23 21:22:48] [WARN] [EVENT] Payload ID bereits verarbeitet: 271
+[2026-02-23 21:22:54] [DEBUG] [DB] Database Insert erfolgreich: INSERT INTO binary_event (value, timestamp) VALUES (?, ?)
+ parameters=[1, 2026-02-23T21:22:54.056980900]
+[2026-02-23 21:22:54] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:22:54] [WARN] [UNREAL] Nicht verbunden! Text wird nicht gesendet!
+[2026-02-23 21:22:54] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:23:01] [INFO] [MQTT] Verbinde mit Broker tcp://localhost:1883
+[2026-02-23 21:23:01] [INFO] [MQTT] Verbindung hergestellt
+[2026-02-23 21:23:02] [INFO] [DB] Datenbank initialisiert
+[2026-02-23 21:23:02] [INFO] [MQTT] Topic abonniert: PREDICTION
+[2026-02-23 21:23:02] [INFO] [Controller] Subscribe AppState Observer gestartet
+[2026-02-23 21:23:02] [INFO] [Controller] AppState Observer registriert
+[2026-02-23 21:23:06] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:23:06] [WARN] [UNREAL] Nicht verbunden! Text wird nicht gesendet!
+[2026-02-23 21:23:06] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:23:12] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:23:12] [WARN] [UNREAL] Nicht verbunden! Text wird nicht gesendet!
+[2026-02-23 21:23:12] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:23:18] [WARN] [EVENT] Payload ID bereits verarbeitet: 274
+[2026-02-23 21:23:24] [WARN] [EVENT] Payload ID bereits verarbeitet: 274
+[2026-02-23 21:23:29] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:23:29] [WARN] [UNREAL] Nicht verbunden! Text wird nicht gesendet!
+[2026-02-23 21:23:29] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:23:35] [WARN] [EVENT] Payload ID bereits verarbeitet: 275
+[2026-02-23 21:23:42] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:23:42] [WARN] [UNREAL] Nicht verbunden! Text wird nicht gesendet!
+[2026-02-23 21:23:42] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:23:47] [WARN] [EVENT] Payload ID bereits verarbeitet: 276
+[2026-02-23 21:23:53] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:23:53] [WARN] [UNREAL] Nicht verbunden! Text wird nicht gesendet!
+[2026-02-23 21:23:53] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:23:59] [WARN] [EVENT] Payload ID bereits verarbeitet: 277
+[2026-02-23 21:24:05] [WARN] [EVENT] Payload ID bereits verarbeitet: 277
+[2026-02-23 21:24:11] [WARN] [EVENT] Payload ID bereits verarbeitet: 277
+[2026-02-23 21:24:17] [WARN] [EVENT] Payload ID bereits verarbeitet: 277
+[2026-02-23 21:24:24] [INFO] [MQTT] Verbinde mit Broker tcp://localhost:1883
+[2026-02-23 21:24:24] [INFO] [MQTT] Verbindung hergestellt
+[2026-02-23 21:24:24] [INFO] [DB] Datenbank initialisiert
+[2026-02-23 21:24:24] [INFO] [MQTT] Topic abonniert: PREDICTION
+[2026-02-23 21:24:24] [INFO] [Controller] Subscribe AppState Observer gestartet
+[2026-02-23 21:24:24] [INFO] [Controller] AppState Observer registriert
+[2026-02-23 21:24:29] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:24:29] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:24:35] [WARN] [EVENT] Payload ID bereits verarbeitet: 277
+[2026-02-23 21:24:41] [WARN] [EVENT] Payload ID bereits verarbeitet: 277
+[2026-02-23 21:24:48] [WARN] [EVENT] Payload ID bereits verarbeitet: 277
+[2026-02-23 21:24:53] [WARN] [EVENT] Payload ID bereits verarbeitet: 277
+[2026-02-23 21:24:59] [WARN] [EVENT] Payload ID bereits verarbeitet: 277
+[2026-02-23 21:25:05] [WARN] [EVENT] Payload ID bereits verarbeitet: 277
+[2026-02-23 21:25:11] [WARN] [EVENT] Payload ID bereits verarbeitet: 277
+[2026-02-23 21:25:17] [WARN] [EVENT] Payload ID bereits verarbeitet: 277
+[2026-02-23 21:25:23] [WARN] [EVENT] Payload ID bereits verarbeitet: 277
+[2026-02-23 21:25:29] [WARN] [EVENT] Payload ID bereits verarbeitet: 277
+[2026-02-23 21:25:35] [WARN] [EVENT] Payload ID bereits verarbeitet: 277
+[2026-02-23 21:25:41] [WARN] [EVENT] Payload ID bereits verarbeitet: 277
+[2026-02-23 21:25:44] [INFO] [MQTT] Verbindung getrennt
+[2026-02-23 21:25:44] [INFO] [PROCESS] Externe Prozesse beendet
+[2026-02-23 21:25:44] [INFO] [SYSTEM] Programm wird beendet
+[2026-02-23 21:25:44] [INFO] [SYSTEM] Datenbank gelöscht
+[2026-02-23 21:29:20] [INFO] [MQTT] Verbinde mit Broker tcp://localhost:1883
+[2026-02-23 21:29:20] [INFO] [MQTT] Verbindung hergestellt
+[2026-02-23 21:29:21] [INFO] [DB] Datenbank initialisiert
+[2026-02-23 21:29:21] [INFO] [MQTT] Topic abonniert: PREDICTION
+[2026-02-23 21:29:21] [INFO] [Controller] Subscribe AppState Observer gestartet
+[2026-02-23 21:29:21] [INFO] [Controller] AppState Observer registriert
+[2026-02-23 21:29:22] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:29:22] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:29:28] [WARN] [EVENT] Payload ID bereits verarbeitet: 277
+[2026-02-23 21:29:34] [WARN] [EVENT] Payload ID bereits verarbeitet: 277
+[2026-02-23 21:29:40] [WARN] [EVENT] Payload ID bereits verarbeitet: 277
+[2026-02-23 21:29:46] [WARN] [EVENT] Payload ID bereits verarbeitet: 277
+[2026-02-23 21:29:52] [WARN] [EVENT] Payload ID bereits verarbeitet: 277
+[2026-02-23 21:29:58] [WARN] [EVENT] Payload ID bereits verarbeitet: 277
+[2026-02-23 21:30:00] [INFO] [MQTT] Verbindung getrennt
+[2026-02-23 21:30:00] [INFO] [PROCESS] Externe Prozesse beendet
+[2026-02-23 21:30:00] [INFO] [SYSTEM] Programm wird beendet
+[2026-02-23 21:30:00] [INFO] [SYSTEM] Datenbank gelöscht
+[2026-02-23 21:30:54] [INFO] [MQTT] Verbinde mit Broker tcp://localhost:1883
+[2026-02-23 21:30:54] [INFO] [MQTT] Verbindung hergestellt
+[2026-02-23 21:30:54] [INFO] [DB] Datenbank initialisiert
+[2026-02-23 21:30:54] [INFO] [MQTT] Topic abonniert: PREDICTION
+[2026-02-23 21:30:54] [INFO] [Controller] Subscribe AppState Observer gestartet
+[2026-02-23 21:30:54] [INFO] [Controller] AppState Observer registriert
+[2026-02-23 21:30:58] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:30:58] [DEBUG] [Controller] ProblemLevel UI aktualisiert → DISASTER
+[2026-02-23 21:31:01] [INFO] [MQTT] Verbindung getrennt
+[2026-02-23 21:31:01] [INFO] [PROCESS] Externe Prozesse beendet
+[2026-02-23 21:31:01] [INFO] [SYSTEM] Programm wird beendet
+[2026-02-23 21:31:01] [INFO] [SYSTEM] Datenbank gelöscht
diff --git a/pom.xml b/pom.xml
index c87ed4c..1df5f30 100644
--- a/pom.xml
+++ b/pom.xml
@@ -52,6 +52,11 @@
jfreechart
1.5.4
+
+ com.formdev
+ flatlaf
+ 2.6
+
\ No newline at end of file
diff --git a/src/main/java/vassistent/App.java b/src/main/java/vassistent/App.java
index 580ce70..cfb1213 100644
--- a/src/main/java/vassistent/App.java
+++ b/src/main/java/vassistent/App.java
@@ -13,6 +13,7 @@ import java.io.File;
public class App {
public static void main(String[] args) {
+ ApplicationInitializer.initLookAndFeel();
ApplicationContext context =
ApplicationInitializer.initialize();
diff --git a/src/main/java/vassistent/bootstrap/ApplicationInitializer.java b/src/main/java/vassistent/bootstrap/ApplicationInitializer.java
index d4cf105..4e05120 100644
--- a/src/main/java/vassistent/bootstrap/ApplicationInitializer.java
+++ b/src/main/java/vassistent/bootstrap/ApplicationInitializer.java
@@ -1,11 +1,13 @@
package vassistent.bootstrap;
+import com.formdev.flatlaf.FlatDarkLaf;
import vassistent.controller.DashboardController;
import vassistent.model.AppState;
import vassistent.service.*;
import vassistent.util.ConfigLoader;
import vassistent.util.Logger;
+import javax.swing.*;
import java.io.InputStream;
import java.util.Properties;
@@ -62,4 +64,12 @@ public class ApplicationInitializer {
return context;
}
+
+ public static void initLookAndFeel() {
+ try {
+ UIManager.setLookAndFeel(new FlatDarkLaf());
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
}
diff --git a/src/main/java/vassistent/controller/AppWindowController.java b/src/main/java/vassistent/controller/AppWindowController.java
index 0168dd1..553e56b 100644
--- a/src/main/java/vassistent/controller/AppWindowController.java
+++ b/src/main/java/vassistent/controller/AppWindowController.java
@@ -68,9 +68,9 @@ public class AppWindowController {
state.addListener(appState -> {
- Logger.debug("Controller",
+ /*Logger.debug("Controller",
"AppState Update erhalten: " +
- appState.getProblemLevel());
+ appState.getProblemLevel());*/
if (window == null) {
Logger.warn("Controller",
diff --git a/src/main/java/vassistent/service/BinaryEventService.java b/src/main/java/vassistent/service/BinaryEventService.java
index 90a10c2..3983f29 100644
--- a/src/main/java/vassistent/service/BinaryEventService.java
+++ b/src/main/java/vassistent/service/BinaryEventService.java
@@ -1,11 +1,15 @@
package vassistent.service;
+import com.google.gson.JsonObject;
+import com.google.gson.JsonParser;
import vassistent.util.Logger;
public class BinaryEventService {
private final DataPersistenceService persistenceService;
private final EvaluationService evaluationService;
+ private Integer lastId = null;
+
public BinaryEventService(
DataPersistenceService persistenceService,
EvaluationService evaluationService
@@ -14,19 +18,45 @@ public class BinaryEventService {
this.evaluationService = evaluationService;
}
- public void handlePayload(String payload) {
- try {
- int value = Integer.parseInt(payload);
+ public synchronized void handlePayload(String payload) {
- if (value != 0 && value != 1) {
- Logger.warn("EVENT", "Ungültiger Wert: " + payload);
+ try {
+
+ JsonObject json = JsonParser.parseString(payload).getAsJsonObject();
+
+ if (!json.has("valid") || !json.get("valid").getAsBoolean()) {
+ Logger.warn("EVENT", "Payload ist nicht valid");
return;
}
- persistenceService.store(value);
+
+ if (!json.has("_id") || !json.has("prediction")) {
+ Logger.warn("EVENT", "Payload unvollständig");
+ return;
+ }
+
+ int id = json.get("_id").getAsInt();
+
+ if (lastId != null && lastId == id) {
+ Logger.warn("EVENT", "Payload ID bereits verarbeitet: " + id);
+ return;
+ }
+
+ lastId = id;
+
+ int prediction = json.get("prediction").getAsInt();
+
+ if (prediction != 0 && prediction != 1) {
+ Logger.warn("EVENT", "Ungültige Prediction: " + prediction);
+ return;
+ }
+
+ persistenceService.store(prediction);
evaluationService.evaluate();
- } catch (NumberFormatException e) {
- Logger.warn("EVENT", "Payload nicht numerisch " + payload);
+ //Logger.debug("EVENT", "Prediction verarbeitet: " + prediction);
+
+ } catch (Exception e) {
+ Logger.error("EVENT", "Payload Verarbeitung fehlgeschlagen: " + payload, e);
}
}
}
diff --git a/src/main/java/vassistent/service/DataPersistenceService.java b/src/main/java/vassistent/service/DataPersistenceService.java
index cf1d934..206a37b 100644
--- a/src/main/java/vassistent/service/DataPersistenceService.java
+++ b/src/main/java/vassistent/service/DataPersistenceService.java
@@ -67,7 +67,7 @@ public class DataPersistenceService {
ps.setInt(1, value);
ps.setString(2, LocalDateTime.now().toString());
ps.executeUpdate();
- Logger.debug("DB", "Database Insert erfolgreich: " + ps.toString());
+ //Logger.debug("DB", "Database Insert erfolgreich: " + ps.toString());
} catch (SQLException e) {
Logger.error("DB", "Database Insert fehlgeschlagen", e);
}
diff --git a/src/main/java/vassistent/service/MqttClientService.java b/src/main/java/vassistent/service/MqttClientService.java
index 496e62b..5ebc64e 100644
--- a/src/main/java/vassistent/service/MqttClientService.java
+++ b/src/main/java/vassistent/service/MqttClientService.java
@@ -99,10 +99,10 @@ public class MqttClientService implements MqttCallback {
String payload =
new String(message.getPayload(), StandardCharsets.UTF_8);
- Logger.debug(
- "MQTT",
- "Nachricht empfangen -> Topic=" + topic + ", Payload=" + payload
- );
+ //Logger.debug(
+ // "MQTT",
+ // "Nachricht empfangen -> Topic=" + topic + ", Payload=" + payload
+ //);
Consumer listener = topicListeners.get(topic);
if (listener != null) {
diff --git a/src/main/java/vassistent/service/ProcessManagerService.java b/src/main/java/vassistent/service/ProcessManagerService.java
index cfc0913..ae62140 100644
--- a/src/main/java/vassistent/service/ProcessManagerService.java
+++ b/src/main/java/vassistent/service/ProcessManagerService.java
@@ -40,18 +40,6 @@ public class ProcessManagerService {
pythonProcess = pb.start();
- // Output Thread starten
- /*new Thread(() -> {
- try (var reader = pythonProcess.inputReader()) {
- String line;
- while ((line = reader.readLine()) != null) {
- Logger.info("PYTHON", line);
- }
- } catch (Exception e) {
- Logger.error("PROCESS", "Python Output Reader Fehler", e);
- }
- }).start();*/
-
Logger.info("PROCESS", "Mqtt Simulator gestartet");
} catch (IOException e) {
Logger.error("PROCESS", "Mqtt Simulator Start fehlgeschlagen", e);
@@ -68,7 +56,14 @@ public class ProcessManagerService {
String exe = config.getProperty("unreal.executable");
- ProcessBuilder pb = new ProcessBuilder(exe);
+ ProcessBuilder pb = new ProcessBuilder(
+ exe,
+ "-RenderOffScreen",
+ "-NoSound",
+ "-PixelStreamingSignallingURL=ws://127.0.0.1:8888"
+ );
+
+ pb.redirectErrorStream(true);
unrealProcess = pb.start();
@@ -82,10 +77,10 @@ public class ProcessManagerService {
public void shutdown() {
if (pythonProcess != null)
- pythonProcess.destroy();
+ pythonProcess.destroyForcibly();
if (unrealProcess != null)
- unrealProcess.destroy();
+ unrealProcess.destroyForcibly();
Logger.info("PROCESS", "Externe Prozesse beendet");
}
diff --git a/src/main/java/vassistent/service/UnrealWebSocketService.java b/src/main/java/vassistent/service/UnrealWebSocketService.java
index 6751efe..b04d359 100644
--- a/src/main/java/vassistent/service/UnrealWebSocketService.java
+++ b/src/main/java/vassistent/service/UnrealWebSocketService.java
@@ -72,7 +72,7 @@ public class UnrealWebSocketService {
public void speak(String text) {
if (!connected.get()) {
- Logger.warn("UNREAL", "Nicht verbunden! Text wird nicht gesendet!");
+ //Logger.warn("UNREAL", "Nicht verbunden! Text wird nicht gesendet!");
return;
}
diff --git a/src/main/java/vassistent/ui/AppWindow.java b/src/main/java/vassistent/ui/AppWindow.java
index 025135b..4b03658 100644
--- a/src/main/java/vassistent/ui/AppWindow.java
+++ b/src/main/java/vassistent/ui/AppWindow.java
@@ -57,7 +57,7 @@ public class AppWindow extends JFrame {
JTabbedPane tabs = new JTabbedPane();
streamingView = new PixelStreamingView(
- "http://localhost",
+ "http://141.75.215.233",
false,
false
);
diff --git a/src/main/resources/config/application.properties b/src/main/resources/config/application.properties
index d1beaf1..e9e8d98 100644
--- a/src/main/resources/config/application.properties
+++ b/src/main/resources/config/application.properties
@@ -8,7 +8,7 @@ python.path="C:\\Program Files\\PyManager\\python.exe"
mqtt.topic=PREDICTION
# ===== MQTT SIMULATOR =====
-mqtt_sim.enabled=true
+mqtt_sim.enabled=false
mqtt_sim.script=src/main/resources/scripts/mqtt_simulator.py
# ===== UNREAL ENGINE =====