diff --git a/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/domain/message/MessageManager.java b/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/domain/message/MessageManager.java new file mode 100644 index 0000000..b3ba0da --- /dev/null +++ b/src/main/java/ch/unibas/dmi/dbis/cs108/casono/server/domain/message/MessageManager.java @@ -0,0 +1,15 @@ +package ch.unibas.dmi.dbis.cs108.casono.server.domain.message; + +import ch.unibas.dmi.dbis.cs108.casono.server.domain.user.UserRegistry; + +public class MessageManager { + private final UserRegistry userRegistry; + + public MessageManager(UserRegistry userRegistry) { + this.userRegistry = userRegistry; + } + + public void broadcast(Message message) { + userRegistry.getAllUsers().forEach(user -> user.enqueueMessage(message)); + } +}