diff --git a/src/main/java/ch/hepia/mq/MessageManager.java b/src/main/java/ch/hepia/mq/MessageManager.java index abb2b1b378d8d8d67a6d066ea41ee229b1ece724..074abbed81be31020977668911265a6669efbd89 100644 --- a/src/main/java/ch/hepia/mq/MessageManager.java +++ b/src/main/java/ch/hepia/mq/MessageManager.java @@ -88,6 +88,7 @@ public class MessageManager extends MessageQueue { public void conditionalSubscribeMeeting(Consumer<Meeting> eventHandler, Predicate<Meeting> condition) { this.conditionalSubscribe(Message.Type.Meeting, eventHandler, condition); } + /** * Subscribe to LeftJourney events validating the condition * @param eventHandler LeftJourney consumer diff --git a/src/main/java/ch/hepia/ui/MainWindowController.java b/src/main/java/ch/hepia/ui/MainWindowController.java index d4483dfa4a6a2c6217af5185d45fb1d8185fc30f..9c84b94cdff4b420b4b599a566d605e2244dc054 100644 --- a/src/main/java/ch/hepia/ui/MainWindowController.java +++ b/src/main/java/ch/hepia/ui/MainWindowController.java @@ -459,6 +459,11 @@ public class MainWindowController implements Initializable { drawMessage(message, leftJourney.getWeatherToDestination(), AppConfig.COLOR_BLUE_10_OPACITY); } }), userFilter::test); + + app.getMessageManager().conditionalSubscribeMeeting(meeting -> Platform.runLater(() -> { + //Consumer code + }), userFilter::test); + } /**