1 files changed, 28 insertions, 0 deletions
diff --git a/mod/src/main/java/moe/ymc/acron/s2c/EventQueue.java b/mod/src/main/java/moe/ymc/acron/s2c/EventQueue.java
new file mode 100644
index 0000000..8c470a1
--- /dev/null
+++ b/mod/src/main/java/moe/ymc/acron/s2c/EventQueue.java
@@ -0,0 +1,28 @@
+package moe.ymc.acron.s2c;
+
+import io.netty.channel.Channel;
+import io.netty.channel.group.ChannelGroup;
+import io.netty.channel.group.DefaultChannelGroup;
+import io.netty.util.concurrent.GlobalEventExecutor;
+import moe.ymc.acron.serialization.Serializer;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+import org.jetbrains.annotations.NotNull;
+
+public class EventQueue {
+    private static final Logger LOGGER = LogManager.getLogger();
+
+    private static final ChannelGroup sMessageRecipients =
+            new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);
+
+    public static void registerMessageRecipient(@NotNull Channel channel) {
+        sMessageRecipients.add(channel);
+    }
+
+    public static void enqueue(@NotNull Event message) {
+        LOGGER.debug("Enqueue: {} ({} channels)",
+                message,
+                sMessageRecipients.size());
+        sMessageRecipients.writeAndFlush(Serializer.serialize(message));
+    }
+}