#46 some more non FX UI updates fixed

patschuh · Jun 10, 2024 · bb03ed3 · bb03ed3
1 parent c2ec244
commit bb03ed3
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 10 deletions.
diff --git a/build.gradle b/build.gradle
@@ -11,7 +11,7 @@ plugins {
 }
 
 group = 'at.esque.kafka'
-version = '2.9.3'
+version = '2.9.4'
 
 repositories {
     mavenCentral()

diff --git a/src/main/java/at/esque/kafka/Controller.java b/src/main/java/at/esque/kafka/Controller.java
@@ -861,7 +861,7 @@ private void getOldestMessages(TopicMessageTypeConfig topic, Map<String, String>
                 });
             } finally {
                 consumerHandler.deregisterConsumer(consumerId);
-                backGroundTaskHolder.backgroundTaskStopped();
+                Platform.runLater(() -> backGroundTaskHolder.backgroundTaskStopped());
             }
 
         });
@@ -964,7 +964,7 @@ private void getNewestMessages(TopicMessageTypeConfig topic, Map<String, String>
                 });
             } finally {
                 consumerHandler.deregisterConsumer(consumerId);
-                backGroundTaskHolder.backgroundTaskStopped();
+                Platform.runLater(() -> backGroundTaskHolder.backgroundTaskStopped());
             }
         });
     }
@@ -1010,7 +1010,7 @@ private <KT, VT> void getMessagesContinuously(TopicMessageTypeConfig topic, Map<
                 });
             } finally {
                 consumerHandler.deregisterConsumer(consumerId);
-                backGroundTaskHolder.backgroundTaskStopped();
+                Platform.runLater(() -> backGroundTaskHolder.backgroundTaskStopped());
             }
         });
     }
@@ -1078,7 +1078,7 @@ private <KT, VT> void trace(TopicMessageTypeConfig topic, Map<String, String> co
                 });
             } finally {
                 consumerHandler.deregisterConsumer(consumerId);
-                backGroundTaskHolder.backgroundTaskStopped();
+                Platform.runLater(() -> backGroundTaskHolder.backgroundTaskStopped());
             }
         });
     }
@@ -1185,7 +1185,7 @@ private void getMessagesFromSpecificOffset(TopicMessageTypeConfig topic, Map<Str
                 });
             } finally {
                 consumerHandler.deregisterConsumer(consumerId);
-                backGroundTaskHolder.backgroundTaskStopped();
+                Platform.runLater(() -> backGroundTaskHolder.backgroundTaskStopped());
             }
         });
     }
@@ -1225,7 +1225,7 @@ private void getMessagesStartingFromInstant(TopicMessageTypeConfig topic, Map<St
                 });
             } finally {
                 consumerHandler.deregisterConsumer(consumerId);
-                backGroundTaskHolder.backgroundTaskStopped();
+                Platform.runLater(() -> backGroundTaskHolder.backgroundTaskStopped());
             }
         });
     }
@@ -1420,7 +1420,7 @@ public void applyTopicTemplatesClick(ActionEvent event) {
             }
             runInDaemonThread(() -> {
                 try {
-                    backGroundTaskHolder.setIsInProgress(true);
+                    Platform.runLater(() -> backGroundTaskHolder.setIsInProgress(true));
                     List<String> alreadyExistedTopics = new ArrayList<>();
                     List<String> createdTopics = new ArrayList<>();
 
@@ -1443,7 +1443,7 @@ public void applyTopicTemplatesClick(ActionEvent event) {
                     });
                     Platform.runLater(() -> TopicTemplateAppliedAlert.show(createdTopics, alreadyExistedTopics, topicListView.getScene().getWindow()));
                 } finally {
-                    backGroundTaskHolder.backgroundTaskStopped();
+                    Platform.runLater(() -> backGroundTaskHolder.backgroundTaskStopped());
                 }
             });
         }
@@ -1515,7 +1515,7 @@ public void playMessageBook(ActionEvent event) {
                     stopWatch.stop();
                     topicToProducerMap.values().forEach(uuid -> producerHandler.deregisterProducer(uuid));
                     LOGGER.info("Message Book completed [{}]", stopWatch);
-                    backGroundTaskHolder.backgroundTaskStopped();
+                    Platform.runLater(() -> backGroundTaskHolder.backgroundTaskStopped());
                 }
             });
         }