From 1eb9ee4624e3b953c5bed06d73b2bb708f984127 Mon Sep 17 00:00:00 2001
From: naumueller <aumni@DESKTOP-7FO40O1.fritz.box>
Date: Sun, 2 Nov 2025 19:10:32 +0100
Subject: [PATCH] Comments and UI Logik added

---
 .../model/MqttJavaClient.java                   |  2 +-
 .../viewmodel/FxViewModel.java                  | 17 ++++++++++-------
 2 files changed, 11 insertions(+), 8 deletions(-)

diff --git a/src/main/java/efi/projekt/gesundheitsassistent/model/MqttJavaClient.java b/src/main/java/efi/projekt/gesundheitsassistent/model/MqttJavaClient.java
index 3a991db..ce5ded9 100644
--- a/src/main/java/efi/projekt/gesundheitsassistent/model/MqttJavaClient.java
+++ b/src/main/java/efi/projekt/gesundheitsassistent/model/MqttJavaClient.java
@@ -89,7 +89,7 @@ public class MqttJavaClient implements MqttCallback {
         System.out.println(" Inhalt: " + new String(message.getPayload()));
         System.out.println(" QoS: " + message.getQos());
 
-        Consumer<String> listener = topicListeners.get(topic);
+        Consumer<String> listener = topicListeners.get(topic); // Consumer<String> aus HashMap holen
         if (listener != null) {
             listener.accept(payload);
         }  
diff --git a/src/main/java/efi/projekt/gesundheitsassistent/viewmodel/FxViewModel.java b/src/main/java/efi/projekt/gesundheitsassistent/viewmodel/FxViewModel.java
index 6589e1e..4fdc0b0 100644
--- a/src/main/java/efi/projekt/gesundheitsassistent/viewmodel/FxViewModel.java
+++ b/src/main/java/efi/projekt/gesundheitsassistent/viewmodel/FxViewModel.java
@@ -16,24 +16,27 @@ import javafx.beans.property.StringProperty;
  * @author naumueller
  */
 public class FxViewModel {
-    
+
     private final FxModel model;
     private Map<String, StringProperty> topicMessages = new HashMap<>();
     private final StringProperty incomingMessage = new SimpleStringProperty("");
     private final StringProperty outgoingMessage = new SimpleStringProperty("");
-    
+
     private final StringProperty messageToSend = new SimpleStringProperty("");
-    
+
     public FxViewModel(FxModel model) {
         this.model = model;
-        
+
         subscribeTopic("Text");
         subscribeTopic("Temperatur");
     }
-    
+
     public void subscribeTopic(String topic) {
-        model.getMqttClient().addTopicListeners(topic, msg -> {
-            Platform.runLater(() -> getTopicProperty(topic).set(msg));
+        model.getMqttClient().addTopicListeners(topic, msg -> { // Consumer<String> mit Lambda-Funktion (wird ausgeführt, wenn message für topic ankommt)
+            Platform.runLater(() -> {
+                getTopicProperty(topic).set(msg); // Richtige Property für topic aus HashMap holen und Message anzeigen.
+                incomingMessage.set(msg);
+            });
         });
     }