kurzti88066/Fahrsimulator_MSY2526_UX
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Comments and UI Logik added

Browse Source
This commit is contained in:
naumueller 2025-11-02 19:10:32 +01:00
parent e4276d6cca
commit 1eb9ee4624
2 changed files with 11 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/efi/projekt/gesundheitsassistent/model/MqttJavaClient.java
View File

@ -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);
}

17
src/main/java/efi/projekt/gesundheitsassistent/viewmodel/FxViewModel.java
View File

@ -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);
});
});
}